python—Celery非同步分散式

Celery  是一個python開發的非同步分散式任務排程模組，是一個訊息傳輸的中介軟體，可以理解為一個郵箱，每當應用程式呼叫celery的非同步任務時，會向broker傳遞訊息，然後celery的worker從中取訊息

Celery  用於儲存訊息以及celery執行的一些訊息和結果

對於brokers，官方推薦是rabbitmq和redis

對於backend，也就是指資料庫，為了簡單一般使用redis

安裝啟動celery:

pip install celery

下面舉個 註冊發驗證碼的 非同步任務：

建立單py檔案，名稱為 tasks.py(必須)

 1 from celery import Celery
 2 
 3 broker_url = 'redis://127.0.0.1:6379/14'          #任務存放指定庫
 4 result_backend = 'redis://127.0.0.1:6379/15'          #任務執行結束存放指定庫
 5 app = Celery('tasks',broker=broker_url,backend=result_backend)
 6 
 7 from yunpian_python_sdk.model import
 
 constant as YC
 8 from yunpian_python_sdk.ypclient import YunpianClient
 9 
10 YUNPIAN_KEY = '5f10ebc31xxxxxxxxxxxxxxxxdf3906994833'
11 
12 @app.task(name='send_sms_code')
13 def send_sms_code(mobile,sms_code):
14     '''
15     非同步傳送手機驗證碼
16     '''
17     clnt = YunpianClient(YUNPIAN_KEY)
18     param = {YC.MOBILE: mobile
 
, YC.TEXT: '【雲片網】您的驗證碼是{}'.format(sms_code)}
19     r = clnt.sms().single_send(param)
20     print('======返回碼{}======API結果{}'.format(r.code(), r.data()))

view.py中呼叫非同步任務：

1 from meiduo_mall.utils.tasks import send_sms_code        #導包
2 
3 sms_code = '{:0>6d}'.format(random.randint(0,999999))    #生成驗證碼
4 
5 send_sms_code.delay(mobile,sms_code)                     #呼叫 非同步任務執行

前後端任務先執行，然後執行：

celery -A tasks worker -l info -P eventlet

 執行 結果：

安裝啟動celery