使用类方法作为芹菜任务

Question

我正在尝试将类的方法用作django-celery任务，并使用@task装饰器对其进行标记。阿南德·杰亚哈（Anand
Jeyahar）询问，这里也描述了同样的情况。是这样的

class A:
    @task
    def foo(self, bar):
        ...

def main():
    a = A()
    ...
    # what i need
    a.foo.delay(bar) # executes as celery task 
    a.foo(bar) # executes locally

问题是，即使我使用这样的类实例a.foo.delay(bar)，也foo需要至少两个参数，这意味着self指针未命中。

更多信息：

• 由于继承，我无法将类转换为 模块
• 方法在很大程度上依赖于类成员，所以我不能使它们成为 静态的
• 标记 类 与@task装饰任务，使一类任务本身，它可能是可以从执行该方法的run()方法，利用一些参数作为方法选择的关键，但它不正是我想要的。
• 创建类的实例并将其作为self参数传递给方法会改变我执行方法的方式，而 不是 像芹菜一样，而是像通常的方法一样（即在测试时）
• 我试图找出如何以动态方式（例如，从构造函数）注册任务，但是celery在工作人员之间共享代码，因此这似乎是不可能的。

谢谢你的帮助！

Answer 1

自3.0版以来，Celery对使用方法作为任务提供了实验性支持。

有关此文件的文档位于中celery.contrib.methods，还提到了一些您应该注意的警告：

https://docs.celeryproject.org/zh/3.1/reference/celery.contrib.methods.html

请注意* ： 自4.0以来 支持contrib.methods从Celery中删除 *