这是一个创建于 459 天前的主题,其中的信息可能已经有所发展或是发生改变。
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 ?
1 条回复 • 2023-07-07 16:16:12 +08:00
|
|
1
julyclyde 2023-07-07 16:16:12 +08:00
我觉得你可以把这俩组件断开,从中间进行诊断 比如我觉得大概不是 celery 的问题,而是 rabbitMQ 的问题,我就会建议你手工用 rabbitMQ 的客户端取一个消息回来,然后不 ack ,直接 kill-9 掉;然后看服务器那边会怎么处理
|