我的发展环境是
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中 .
为什么不执行任务?
对我有什么帮助吗?