请教一个 celery worker 掉电任务丢失的问题

This topic created in 1053 days ago, the information mentioned may be changed or developed.

celery 5.2.7
backend redis
broker rabbitmq 3.8.25-management
设置 task_reject_on_worker_lost = True task_acks_late = True
两台机器，worker 接收到任务后，worker 关机，在 rabbitmq 管理界面发现消息已经被消费，有大佬知道是什么原因吗？还是说 rabbitmq 要关闭 auto ack ？

Worker

rabbitmq

Celery

true

1 replies • 2023-07-07 16:16:12 +08:00

julyclyde

Jul 7, 2023

我觉得你可以把这俩组件断开，从中间进行诊断
比如我觉得大概不是 celery 的问题，而是 rabbitMQ 的问题，我就会建议你手工用 rabbitMQ 的客户端取一个消息回来，然后不 ack ，直接 kill-9 掉；然后看服务器那边会怎么处理