Celery 任务和子任务有什么区别？

Question

如果我对本教程的理解正确，Celery subtask 支持与 task 几乎相同的 API，但还有一个额外的优势，即它可以传递给其他函数或进程.

显然，如果是这样的话，Celery 会简单地将 tasks 替换为 subtasks 而不是保留两者（例如，@app.task 装饰器会转换一个函数子任务而不是任务等）。所以我一定是误会了什么。

任务能做什么而子任务不能？

Celery API 发生了很大变化；我的问题是针对 3.1 版（目前是最新版）。

编辑：

我知道文档说 subtasks 旨在从其他 tasks 中调用。我的问题是什么阻止 Celery 完全摆脱任务并在任何地方使用子任务？它们似乎比任务更灵活/更强大：

# tasks.py
from celery import Celery
app = Celery(backend='rpc://')

@app.task
def add(x, y):
    # just print out a log line for testing purposes
    print(x, y)

# client.py
from tasks import add
add_subtask = add.subtask()
# in this context, it seems the following two lines do the same thing
add.delay(2, 2)
add_subtask.delay(2, 2)
# when we need to pass argument to other tasks, we must use add_subtask
# so it seems add_subtask is strictly better than add

Answer 1

当您开始将complex workflows 与 celery 一起使用时，您会考虑到差异。

签名() 包装参数、关键字参数和执行 单个任务调用的选项，使得它可以 传递给函数，甚至序列化并通过网络发送。

签名通常被称为“子任务”，因为它们描述了一项任务 在任务中调用。

还有：

子任务是用于传递任务签名的对象 调用，（例如通过网络发送）

Task 只是一个用装饰器包装的函数定义，而subtask 是一个传递了参数但尚未开始的任务。您可以通过网络传输序列化的子任务，或者更常用的是，在组/链/和弦中调用它。