python - celery python对象方法

Question

我正在尝试围绕 python 对象方法获取 celery 任务包装器。喜欢:

 class A:
      @task
      def test_task(self,args):
        print "BLah..test"

   def main():
     a= A()
     args = {}
     a.test_task(args)

现在失败并出现错误 test_task 需要至少 2 个参数(给定 1 个)。我的理解是 self 对象没有通过。为什么会这样？我该如何解决这个问题？

更新: 这真的是我对 celery 缺乏了解。 @task 装饰器只是添加/处理与 celery 任务相关的参数。它不会自动使对函数的每次调用都成为 celery 任务。该函数必须被称为 a.test_task.delay(args).. 其中的问题...

Answer 1

从 3.0 版本开始，Celery 现在支持使用方法作为任务: http://docs.celeryproject.org/en/latest/reference/celery.contrib.methods.html