运行 同时存在多个 Celery 链
Run multiple Celery chains at the same time
我有使用 apply_async
调用的 Celery 任务链。链中的每个任务都取决于前一个任务的结果。
worklof 基本上是这样的:
- 从数据库中获取数据。
- 对于每个获取的行 运行 任务链。
我想要实现的行为是一次 运行 多个链。但似乎 运行 将它们排成一行,而不是同时。如何解决这个问题?
如果你想一次 运行 链接你需要 运行 多个工人。
我有使用 apply_async
调用的 Celery 任务链。链中的每个任务都取决于前一个任务的结果。
worklof 基本上是这样的:
- 从数据库中获取数据。
- 对于每个获取的行 运行 任务链。
我想要实现的行为是一次 运行 多个链。但似乎 运行 将它们排成一行,而不是同时。如何解决这个问题?
如果你想一次 运行 链接你需要 运行 多个工人。