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

2023-07-07 11:10:31 +08:00
 rationa1cuzz
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 ?
319 次点击
所在节点    问与答
1 条回复
julyclyde
2023-07-07 16:16:12 +08:00
我觉得你可以把这俩组件断开,从中间进行诊断
比如我觉得大概不是 celery 的问题,而是 rabbitMQ 的问题,我就会建议你手工用 rabbitMQ 的客户端取一个消息回来,然后不 ack ,直接 kill-9 掉;然后看服务器那边会怎么处理

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/954805

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX