python - 将 n 个任务添加到 celery 队列并等待结果

Question

我会在 celery 队列中添加几个作业并等待结果。我对如何使用某种类型的共享存储(memcached、redis、数据库等)来实现这一点有很多想法，但我认为这是 Celery 可以自动处理的东西，但我在网上找不到任何资源。

代码示例

def do_tasks(b):
    for a in b:
        c.delay(a)

    return c.all_results_some_how()

Answer 1

对于 Celery >= 3.0，TaskSet 为 deprecated赞成group .

from celery import group
from tasks import add

job = group([
             add.s(2, 2),
             add.s(4, 4),
             add.s(8, 8),
             add.s(16, 16),
             add.s(32, 32),
])

在后台启动群组:

result = job.apply_async()

等待:

result.join()