Django下使用celery 異步發送短信驗證碼

celery

1.celery介紹

1.1 celery應用舉例

• Celery 是一個 基于python開發的分布式異步訊息任務佇列，通過它可以輕松的實作任務的異步處理，如果你的業務場景中需要用到異步任務，就可以考慮使用celery
• 你想對100臺機器執行一條批量命令，可能會花很長時間 ，但你不想讓你的程式等著結果回傳，而是給你回傳 一個任務ID,你過一段時間只需要拿著這個任務id就可以拿到任務執行結果， 在任務執行ing進行時，你可以繼續做其它的事情
• Celery 在執行任務時需要通過一個訊息中間件來接收和發送任務訊息，以及存盤任務結果， 一般使用rabbitMQ or Redis

1.2 Celery有以下優點

• 簡單：一單熟悉了celery的作業流程后，配置和使用還是比較簡單的
• 高可用：當任務執行失敗或執行程序中發生連接中斷，celery 會自動嘗試重新執行任務
• 快速：一個單行程的celery每分鐘可處理上百萬個任務
• 靈活： 幾乎celery的各個組件都可以被擴展及自定制

1.3 Celery 特性

• 方便查看定時任務的執行情況, 如 是否成功, 當前狀態, 執行任務花費的時間等.
• 可選 多行程, Eventlet 和 Gevent 三種模型并發執行.
• Celery 是語言無關的.它提供了python 等常見語言的介面支持.

2.作業原理

2.1 Celery 扮演生產者和消費者的角色

• Celery Beat : 任務調度器. Beat 行程會讀取組態檔的內容, 周期性的將配置中到期需要執行的任務發送給任務佇列.
• Celery Worker : 執行任務的消費者, 通常會在多臺服務器運行多個消費者, 提高運行效率.
• Broker : 訊息代理, 佇列本身. 也稱為訊息中間件. 接受任務生產者發送過來的任務訊息, 存進佇列再按序分發給任務消費方(通常是訊息佇列或者資料庫).
• Producer : 任務生產者. 呼叫 Celery API , 函式或者裝飾器, 而產生任務并交給任務佇列處理的都是任務生產者.
• Result Backend : 任務處理完成之后保存狀態資訊和結果, 以供查詢.

3.異步發短信

1.settings同級目錄下創建 celery 檔案

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 設定環境變數
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo.settings')

# 注冊Celery的APP
app = Celery('meiduo')
# 系結組態檔
app.config_from_object('django.conf:settings', namespace='CELERY')

# 自動發現各個app下的tasks.py檔案
app.autodiscover_tasks()

2.配置settings檔案

CELERY_BROKER_URL = 'redis://127.0.0.1:6379/'

CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/'

CELERY_RESULT_SERIALIZER = 'json'

3 配置 settings同級目錄下 init 檔案

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app

__all__ = ['celery_app']

4.在utils下新建一個task.py檔案

from celery.task import task
from .comm import send_message

# 定義發送郵件的方法
@task
def mail(mobile,code):
    send_message(mobile,code,5)
    

5.介面中呼叫

from utils.tasks import mail
import random
class SendMes(APIView):
    # 短信驗證
    def get(self,request):
        # 接收客戶端發送的資料
        imagecode = request.query_params.get('imagecode')
        print(imagecode)
        mobile = request.query_params.get('mobile')
        print(mobile)
        uuid = request.query_params.get('uuid')
        print(uuid)
        if not all([imagecode,mobile]):
            return Response({'msg':'沒有獲取到'})
        # 驗證圖片驗證碼
        conn =get_redis_conn()
        # redis 中取驗證碼
        code = conn.get(uuid)
        print(code)
        if code:
            code = str(code,encoding='utf8')
            # 圖片驗證碼對比
            if imagecode.lower() == code.lower():
                # 驗證通過后呼叫發送短信介面
                sms_code = random.randint(10000,99999)
                # 重點 重點 重點！！！！！！！
                result = mail.delay(mobile,sms_code,1)
               # 加入短信嗎發送成功
                if result:
                    # redis中要存短信驗證嗎
                    conn.setex(mobile,60,sms_code)
                    # 把圖片驗證碼從redis中洗掉
                    conn.delete(uuid)
                    return Response({'msg':sms_code})
                else:
                    return ({'msg':'發送失敗'})
            else:
                return Response({'msg':'驗證碼不正確'})
        return Response('ok')

6 .先啟動django專案 然后另開終端 cd到專案 目錄下啟動celery 服務

指定并發數 --autoscale(最多,最少)

celery worker -A meiduo --loglevel=info --pool=solo --autoscale=50,5