芹菜无法从给定任务中获得结果

Question

我尝试用 rabbitmq 配置芹菜。服务器工作正常，我的工作程序接收任务并返回成功的结果，但通信（？我正在遵循芹菜文档的第一步。我启动了任务工作者并创建了文件 tasks.py。我的连接：

app = Celery('tasks', backend='amqp', broker='amqp://')

工人内部日志（正确）：

[2015-03-13 21:00:46,146: INFO/MainProcess] Task tasks.add[ee0fd026-d08e-4380-b010-9bbe65cb8b8f] succeeded in 0.00891784499981s: 4

但无法获取结果，状态为待处理

add_task = tasks.add.delay(2,2)
In [4]: add_task.status
Out[4]: 'PENDING'

Answer 1

add_task.status在

排队后立即获取任务的状态（请记住，您使用的是.delay，而不是立即执行它），这将是PENDING。

要从后端获取任务的状态，请使用 AsyncResult 。

res = tasks.add.AsyncResult(add_task.task_id)

这将起作用，除非您已将后端设置为忽略任务结果。