向celery队列添加n个任务，然后等待结果

  • Z时代
  • 2024-01-10
  • 分类：问答

我将向celery队列添加多个任务并等待结果。我有各种各样的想法，我将如何利用某种形式的共享存储（memcached，redis，db等）来实现这一目标，但是，我本以为Celery可以自动处理该问题，但我无法在线找到任何资源。

代码示例

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

回答：

对于Celery > = 3.0，使用taskset被弃用赞成组。

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()

以上是 向celery队列添加n个任务，然后等待结果 的全部内容， 来源链接： utcz.com/qa/431812.html

回到顶部