celery_demo.py

import time

from celery import Celery

broker = 'redis://:123456@localhost/1'#存儲任務

backend = 'redis://:123456@localhost/2'#存儲任務執行結果

app = Celery('demo', broker=broker, backend=backend)


@app.task
def add(x, y):
    z = x + y
    print(f'求和{x}+{y}={z}')
    time.sleep(1)
    return z

____________________________________________________________________________________________________________________________________

add_task.py

from celery_demo import add

res = add.delay(7, 8)  
print(res)　　# 返回一個uuid(異步調用)
右鍵運行腳本，提交此任務，但不會執行

____________________________________________________________________________________________________________________________________

終端命令：
1.啟動worker，worker會執行被提交的任務，把執行結果存入redis的2號庫
celery -A celery_demo worker -l info