我刚刚安装了Celery,我正在尝试按照教程:
我有一个名为tasks.py的文件,其中包含以下代码:
from celery import Celery app = Celery('tasks', backend='amqp', broker='amqp://') @app.task def add(x, y): return x + y
我安装了RabitMQ(我没有配置它,因为教程没有提到任何类似的东西).
我按如下方式运行芹菜工作服务器:
celery -A tasks worker --loglevel=info
它似乎正常启动(这是输出:http://i.imgur.com/qnoNCzJ.png)
然后我运行以下脚本:
from tasks import add from time import sleep result = add.delay(2,2) while not result.ready(): sleep(10)
当我检查时,result.ready()
我总是得到假(所以上面的while循环永远运行).然而,在Celery日志上,一切看起来都很好:
[2014-10-30 00:58:46,673: INFO/MainProcess] Received task: tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] [2014-10-30 00:58:46,674: INFO/MainProcess] Task tasks.add[2bc4ceba-1319-49ce-962d-1ed0a424a2ce] succeeded in 0.000999927520752s: 4
所以这项任务得到了回应,并取得了成功.然而,result.ready()
仍然是假的.任何有关为什么会这样的见解?我在Windows 7上,正在使用RabbitMQ.提前致谢.