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

[kenneth]

想将类成员方法作为celery task,但是后端没有收到消息。
求方法，我试了几次不行，不知道哪里错了

[gfreezy]

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

[yishenggudou]

celery 太折腾 不推荐

[zhenyi2697]

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

[ritksm]

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

[kenneth]

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

[ritksm]

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

[kenneth]

class A:
def __init__(self, feed):

@celery.task
def process(self):
return

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

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

[wenbinwu]

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

[kenneth]

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

[wenbinwu]

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

[kenneth]

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

[wenbinwu]

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

[kenneth]

@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)

[ritksm]

参见以下代码：
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

[kenneth]

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

[ritksm]

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

[kenneth]

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

[Archangel_SDY]

看看broker的log呢?

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

[zhenyi2697]

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

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