运行 同时存在多个 Celery 链

Run multiple Celery chains at the same time

我有使用 apply_async 调用的 Celery 任务链。链中的每个任务都取决于前一个任务的结果。

worklof 基本上是这样的:

  1. 从数据库中获取数据。
  2. 对于每个获取的行 运行 任务链。

我想要实现的行为是一次 运行 多个链。但似乎 运行 将它们排成一行,而不是同时。如何解决这个问题?

如果你想一次 运行 链接你需要 运行 多个工人。