在不同的豆荚中与多个工人一起使用芹菜

我猜您使用的是基本任务类型,它使用“直接”队列类型,而不是“扇出”或“主题”队列,后两者有很大的区别,这里将不讨论。

list 对象作为队列的存储( source ),使用命令 LPUSH BRPOP 使用消息。

BRPOP公司 ( doc this operation is atomic ,没有两个连接可以获得相同的元素。

芹菜利用此功能来保证 消息传递。使用回执不影响本保证。

任务消息不会从队列中删除,直到该消息已被工作人员确认。工作进程可以提前保留许多消息,即使该工作进程因电源故障或其他原因而死亡,该消息也会重新传递给另一个工作进程。

更多信息: http://docs.celeryproject.org/en/latest/userguide/tasks.html