python - Celery @task 不适用于实例方法

Question

我有一个用芹菜@task装饰的方法的类，如下所示：

class Port(object): 

    """docstring for Port"""


    def __init__(self,):
        print 'Class has been initialized ...'


    @celery.task(filter=task_method,name="Port.process")    
    def process(self,):
        print "I'm inside the process task method: "

在这里调用：

p = Port()

p.process.apply_async()

我也试过: p.process.delay()，结果相同。

当我运行它时，我得到这个错误：

[2013-06-22 02:32:53,988: ERROR/MainProcess] Task Port.process[77cff07e-4bc5-4e36-9c4e-b68d7616c74e] raised exception: TypeError('process() takes at least 1 argument (0 given)',) Traceback (most recent call last): File "/usr/local/lib/python2.7/site-packages/celery/task/trace.py", line 228, in trace_task R = retval = fun(*args, **kwargs) File "/usr/local/lib/python2.7/site-packages/celery/task/trace.py", line 415, in __protected_call__ return self.run(*args, **kwargs) TypeError: process() takes at least 1 argument (0 given)

这是重要的部分，TypeError: process() takes at least 1 argument (0 given)。

现在我该如何解决这个问题？

有人说这是因为 celery 使用了未绑定到初始化对象的方法 task，而另一些人说它只是工作，我在这里错过了什么吗？

score 3 · Accepted Answer

Celery 自 3.0 版起实验性地支持将方法用作任务。

这方面的文档在中celery.contrib.methods，并且还提到了一些您应该注意的警告：

http://docs.celeryproject.org/en/latest/reference/celery.contrib.methods.html

以此为参考

python - Celery @task 不适用于实例方法

1 回答 1

Related

Reference