Django中通過celery完成非同步任務
阿新 • • 發佈:2018-11-30
開發環境: Django:1.11
專案佈局
安裝 celery: pip install celery
非同步任務模組 celery_tasks
;
非同步任務: sms (傳送簡訊);
config: celery非同步任務的配置(這裡是用來指名非同步任務儲存的位置);
main: 是整個非同步任務的配置
在main.py
中
在 config.py配置檔案中 :
broker_url = "redis://127.0.0.1/14"
注意:由於這裡在定義和配置celery的時候,是已經獲取了django的配置,所以可以直接使用redis://127.0.0.1/14 的具體地址,單獨使用的話,需要進行相關配置的;參考: http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#broker-redis
在 tasks.py中,定義相關的任務:
參考程式碼:
@app.task
def add(x, y):
return x + y
執行Celery工作伺服器
celery -A 專案名 worker --loglevel=info
# 簡寫
celery -A 專案名 worker -l info
呼叫非同步任務
使用 任務名.delay()
即可
比如:
from tasks import add
add.delay(4, 4)