芹菜任务消失 - Django/Celery

Question

这是我的代码：

我的任务

from celery.decorators import task

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

使用我的任务

from core.tasks import add

results = []

for i in range(100):
    results.append(add.delay(i, i))

---

问题 1

几秒钟后，我执行以下操作：

for result in results:
    print result.result

打印这个：

（这些值不会以看起来像模式的形式返回）

None
None
None
None
8
None
None
None
None
18
None
None
None
None
28
None
None
None
None
38
...

第二次干净的操作系统安装+设置：

一切都按预期工作，仍然不确定这里发生了什么......

---

Django 管理界面中的任务也随机丢失...

---

有人知道发生了什么吗？ :|

Answer 1

task.delay() 是异步的。顺便说一句，整个 AMQP 都是关于使任务异步的。如果你想要同步行为，那么使用 celery 有什么意义呢？

from celery.decorators import task

@task()
def add(x, y, results):
    results.append(x + y)

------------8<-------------
from core.tasks import add

results = []

for i in range(100):
    add.delay(i, i, results)

在打印前等待几秒钟（在消费者做他们的工作时），并注意结果可能会出现乱序。

方法 task.delay 将返回一个 celery.result.AsyncResult 实例。在使用 AsyncResult.result 之前，您应该检查 AsyncResult.state == SUCCESS。

您的最终打印循环可能是：

for result in results:
    while not result.state.ready():
        time.sleep(secs)
    if result.state == u'SUCCESS':
        print result.result
    else:
        print "Something Rotten in the State of Denmark..."

这（几乎）与以下内容相同：

for result in results:
    print result.get()

看TaskSets，它们比将结果存储在列表中更好。

在实践中，人们将结果存储在数据库中，并将等待循环放置在客户端中，然后每隔几秒通过 AJAX 敲击服务器，直到完成。