我尝试在 Windows 上使用 redis 后端运行 Celery 示例。代码如下:
from celery import Celery
app = Celery('risktools.distributed.celery_tasks',
backend='redis://localhost',
broker='redis://localhost')
@app.task(ignore_result=False)
def add(x, y):
return x + y
@app.task(ignore_result=False)
def add_2(x, y):
return x + y
我使用 iPython 控制台启动任务:
>>> result_1 = add.delay(1, 2)
>>> result_1.state
'PENDING'
>>> result_2 = add_2.delay(2, 3)
>>> result_2.state
'PENDING'
好像两个任务都没有执行,但是Celery worker输出显示执行成功了:
[2014-12-08 15:00:09,262: INFO/MainProcess] Received task: risktools.distributed.celery_tasks.add[01dedca1-2db2-48df-a4d6-2f06fe285e45]
[2014-12-08 15:00:09,267: INFO/MainProcess] Task celery_tasks.add[01dedca1-2db2-48df-a4d6-2f06fe28
5e45] succeeded in 0.0019998550415s: 3
[2014-12-08 15:00:24,219: INFO/MainProcess] Received task: risktools.distributed.celery_tasks.add[cb5505ce-cf93-4f5e-aebb-9b2d98a11320]
[2014-12-08 15:00:24,230: INFO/MainProcess] Task celery_tasks.add[cb5505ce-cf93-4f5e-aebb-9b2d98a1
1320] succeeded in 0.010999917984s: 5
我已尝试根据 Celery documentation 解决此问题,但这些建议都没有用。我哪里做错了,我怎样才能收到 Celery 任务的结果?
更新:
我添加了一个没有 ignore_result
参数的任务,但没有任何改变
@app.task
def add_3(x, y):
return x + y
>>>r = add_3.delay(2, 2)
>>>r.state
'PENDING'
最佳答案
根据 Celery 'Getting Started' not able to retrieve results; always pending和 https://github.com/celery/celery/issues/2146这是一个Windows问题。 Celery --pool=solo
选项解决了这个问题。
关于python - celery 任务总是挂起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27357732/