如何在远程任务中使用 Celery 原语？

Question

我想在另一个系统上的任务上使用 celery 的工作流程，例如组和和弦。目前使用 send_task() 来执行这些任务，但现在需要对大量这些远程任务进行分组。

也有兴趣知道组是否有自己的 id 字段可供参考。

我浏览了 Celery 文档，但似乎找不到与使用原语与远程任务有关的任何内容。

Answer 1

也无法从文档中找到执行此操作的方法。我发现了一个 GitHub 线程 讨论类似的事情。使用签名似乎有效。但是，不确定这是否是最好的解决方案：

app = Celery()
a = app.signature('proj.tasks.add', (2, 2))
b = app.signature('proj.tasks.add', (4, 4))

g = group([a, b], app=app)
result = g()
print(result.get())