1. 程式人生 > >Django中通過celery完成非同步任務

Django中通過celery完成非同步任務

開發環境: 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)