Celery Task not working

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

処理するタスクを取得するには、ワーカーを起動する必要があります。

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