无法从 Django 应用程序调用芹菜任务（缺少位置参数）

Question

好的，我已经翻遍了所有的 SO 帖子、Celery 文档等……我就是想不通。无论我尝试什么或如何尝试从 Django 应用程序调用任务，Celery 都会抱怨我没有提供所需的参数。

“TypeError: add() 缺少 2 个必需的位置参数：'x' 和 'y'”。

我从他们的文档中遵循了一个非常简单的示例...仅使用延迟，例如：

add.delay(1, 2)

仍然是同样的错误。我还尝试了add.delay(x=1, y=2)、celery.send_task("add", [1, 2]) 以及其他各种我在各种帖子中看到任务调用的方法，但它们都不起作用。

方法很简单：

@shared_task
def add(x, y):
    return x + y

我也试过命名，比如：

@task(name="my_add")
def add(x, y):
    return x + y

同样的结果。我还可能缺少什么？

Answer 1

首先，您应该在与您的 Django 和 Celery 配置相关的帖子中添加更多信息。

但我认为您的错误在于 @task 装饰器，因为您似乎需要使用 绑定任务：

• 绑定的任务意味着该任务的第一个参数将始终 是任务实例（self），就像 Python 绑定的方法一样。 Reference。
• 另一方面，bind 参数意味着该函数将是一个“绑定方法”，以便您可以访问任务类型实例上的属性和方法。 Reference

所以你的代码应该是这样的：

import celery

@task(bind=True, name="my_add")
def add(self, x, y):
    return x + y

请注意，任务装饰器的 bind 参数将允许访问 self（任务类型实例）。

最后我建议你再次查看Celery setup on Django。