芹菜任務不工作

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