芹菜接收任务但不返回结果,只是保持挂起
celery receiving tasks but not returning results, just keeps pending
from time import sleep
from celery import Celery
backend = 'db+sqlite:///db.sqlite3'
app = Celery('tasks', broker='amqp********************', backend=backend)
@app.task()
def reverse(text):
sleep(5)
return text[::-1]
所以我有上面的代码,当我 运行 代码不起作用时,celery 刚刚收到任务但什么都不做,
检查我待处理的任务的状态
我使用下面的命令来 运行 芹菜,我已经尝试了这里的所有其他解决方案,仍然是一样的。
celery -A tasks worker --loglevel=info
使用类似这样的东西,
celery -A tasks worker -l info --without-gossip --without-mingle --without-heartbeat -Ofair --pool=solo
我想 Celery 会尝试从您的代理中批量获取任务
from time import sleep
from celery import Celery
backend = 'db+sqlite:///db.sqlite3'
app = Celery('tasks', broker='amqp********************', backend=backend)
@app.task()
def reverse(text):
sleep(5)
return text[::-1]
所以我有上面的代码,当我 运行 代码不起作用时,celery 刚刚收到任务但什么都不做, 检查我待处理的任务的状态 我使用下面的命令来 运行 芹菜,我已经尝试了这里的所有其他解决方案,仍然是一样的。
celery -A tasks worker --loglevel=info
使用类似这样的东西,
celery -A tasks worker -l info --without-gossip --without-mingle --without-heartbeat -Ofair --pool=solo
我想 Celery 会尝试从您的代理中批量获取任务