如何将类成员方法作为celery任务？

新写一个function作为celery_task，里面调用 类成员方法

celery 太折腾 不推荐

@yishenggudou 那消息队列有什么推荐的呢?

@ritksm 这篇文章我看到了，但是我没能成功，broker还是没有收到消息。

@kenneth 检查配置、检查log、检查调用的shell命令、贴出代码。要不然别人怎么发现你的问题？

class A:
def __init__(self, feed):

@celery.task
def process(self):
return

a = A()
a.process.delay(feed)

@ritksm 但是不行。高手们帮看下。

@kenneth 你的代码貌似没参考@ritksm 给你的文档啊

@wenbinwu 已经给出了关键信息了，就是调用类方法作为任务，这就是核心问题。

@kenneth 你再读一下那个连接。。。

@wenbinwu 读过了，还是不知道问题在哪里？

@kenneth 你按照第一个例子改一下，别用 ` @celery.task `

@wenbinwu

Traceback (most recent call last):
File "/usr/local/lib/python2.7/dist-packages/celery/task/trace.py", line 233, in trace_task
R = retval = fun(*args, **kwargs)
File "/usr/local/lib/python2.7/dist-packages/celery/task/trace.py", line 420, in __protected_call__
return self.run(*args, **kwargs)
None: process() takes exactly 1 argument (0 given)

参见以下代码：
from celery import Celery
from celery.contrib.methods import task_method

celery = Celery('xxxxx', broker='xxxxxx')

class A(object):

@celery.task(filter=task_method)
def process(self):
print('ok')
return

@ritksm 试了，这种方法就根本收不到消息，跑都不跑。

如何不跑了。。。我咋就可以出结果。。。难道要我截图出来么。。。错误信息？shell是如何调用celery的。。。

@ritksm 没有错误，只是worker收不到job。我们加下Gtalk交流吧:[email protected]

看看broker的log呢?

上次被RabbitMQ的1G磁盘剩余空间要求坑了整整一晚上...

@kenneth 貌似调用celery需要task所在的module是一个celerymodule

也就是说，你需要先运行 celery = Celery('xxxxx', broker='xxxxxx') 创建一个celery的app，然后再写你的task。
另外，你需要运行一个celery的worker，参考 celery -A app_name worker --loglevel=info