我的发展环境是

base:python 2.7,Django == 1.11,celery == 3.1.25

VM #01 : nginx + gunicorn (web)
VM #02 : RabbitMQ server on ubuntu 14.04
VM #03 : celery worker

案例#1:正常工作

  • RabbitMQ正在运行

  • 芹菜 Worker 跑步

  • 并将异步消息推送到rabbitmq =>它工作得很好,

案例#2:接收任务但不要在工作人员中开火 .

  • RabbitMQ正在运行

  • 将异步消息推送到rabbitmq(不运行worker)

  • 然后执行celeryd worker

=>它收到任务但不起作用 . ..

对于#2的情况,芹菜日志是

[2017-07-13 14:37:21,327: INFO/MainProcess] Received task: task.campaign.update_revenues[faf1b584-9af9-437f-a5e5-ce54749b73e9]

就这样 . 没有更多的日志 . 没有任务日志(成功?失败?) . 并且该消息仍然存在于rabbitmq中 .

为什么不执行任务?

对我有什么帮助吗?