Celery Task not working

Question

지연()을 사용할 때마다 아무 일도 일어나지 않습니다.

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