如何同时获得多个芹菜任务结果？

Question

所以我们可以使用sometask.appy_async()启动一个celery任务，使用sometask.AsyncResult(task_id)查询结果。

现在的情况是我开始了一些任务，我想同时查询它们的结果。伪代码为：sometask.AsyncResult(task_1, task_2, task_3)

我使用 Redis 来存储结果，我知道在 Redis 中您可以使用 MGET KEY1 KEY2 .. KEYN 在一个命令中检索多个键值。那我怎么用芹菜做呢？

Answer 1

实现这一目标的最简单方法是使用 Celery 工作流程。更准确地说 - Group 原语。 Group 的重要之处在于它返回 GroupResult（将其视为 AsyncResults 的集合）。