芹菜 AsyncResult - 不工作

Question

我是 celery 的新手，但在简单的事情上却失败了：

后端和代理都为 RabbitMQ 配置

任务如下：

@app.task
def add(x, y):
    return x + y

测试代码：

文件 1：

from tasks import add
from celery import uuid
task_id = uuid()
result = add.delay(7, 2)
task_id = result.task_id
print task_id
# output = 
         05f3f783-a538-45ed-89e3-c836a2623e8a
print result.get()
# output = 
          9

文件 2：

from tasks import add
from celery.result import AsyncResult

res = AsyncResult('05f3f783-a538-45ed-89e3-c836a2623e8a')
print res.state
# output =
         pending
print ('Result =  %s' %res.get())

我的理解是文件 2 应该检索值 success 和 9。

我已经安装了花：

这会报告成功，结果为 9。

帮助。这让我发疯了。

谢谢

Answer 1

也许您应该read the FineManual 并三思而后行？

RPC 结果后端（RabbitMQ/QPid）

RPC 结果后端 (rpc://) 很特殊，因为 它实际上并不存储状态，而是发送 它们作为消息。这是一个重要的区别，因为它意味着 结果只能被检索一次，并且只能由 启动任务。两个不同的进程不能等待同一个进程 结果。

(...)

消息默认是瞬态的（非持久的），所以结果 如果代理重新启动，将消失。您可以配置结果 后端使用 result_persistent 发送持久消息 设置。