芹菜任务不工作

Question

每次我尝试使用delay（）都不会发生。

from celery import Celery 

app = Celery('tasks', broker='redis://localhost:6379') 

@app.task 
def run(msg): 
    print(msg) 

word="xxx" 
run.delay(word) 

我用ping检查过redis，它似乎正在工作。 或者我应该使用不同的东西来运行Flask应用程序中的后台线程？

Answer 1

您需要启动worker以获取要处理的任务。

http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html#id9