最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Django使用celery異步發(fā)送短信驗證碼代碼示例

 更新時間:2021年09月04日 16:06:14   作者:一只阿龍  
這篇文章主要介紹了Django中如何使用celery異步發(fā)送短信驗證碼的代碼示例,有需要的朋友可以借鑒參考下,希望可以對大家有所幫助

celery

1.celery介紹

1.1 celery應用舉例

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

1.2 Celery有以下優(yōu)點

簡單:一單熟悉了celery的工作流程后,配置和使用還是比較簡單的

高可用:當任務執(zhí)行失敗或執(zhí)行過程中發(fā)生連接中斷,celery 會自動嘗試重新執(zhí)行任務快速:一個單進程的celery每分鐘可處理上百萬個任務

靈活: 幾乎celery的各個組件都可以被擴展及自定制

1.3 Celery 特性

方便查看定時任務的執(zhí)行情況, 如 是否成功, 當前狀態(tài), 執(zhí)行任務花費的時間等.

可選 多進程, Eventlet 和 Gevent 三種模型并發(fā)執(zhí)行.

Celery 是語言無關的.它提供了python 等常見語言的接口支持.

2.工作原理

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

 Celery Beat : 任務調度器. Beat 進程會讀取配置文件的內容, 周期性的將配置中到期需要執(zhí)行的任務發(fā)送給任務隊列.

Celery Worker : 執(zhí)行任務的消費者, 通常會在多臺服務器運行多個消費者, 提高運行效率.

Broker : 消息代理, 隊列本身. 也稱為消息中間件. 接受任務生產者發(fā)送過來的任務消息, 存進隊列再按序分發(fā)給任務消費方(通常是消息隊列或者數據庫).

Producer : 任務生產者. 調用 Celery API , 函數或者裝飾器, 而產生任務并交給任務隊列處理的都是任務生產者.

Result Backend : 任務處理完成之后保存狀態(tài)信息和結果, 以供查詢.

3.異步發(fā)短信

1.settings同級目錄下創(chuàng)建 celery 文件

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# 設置環(huán)境變量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo.settings')
# 注冊Celery的APP
app = Celery('meiduo')
# 綁定配置文件
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自動發(fā)現各個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

# 定義發(fā)送郵件的方法
@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):
        # 接收客戶端發(fā)送的數據
        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():
                # 驗證通過后調用發(fā)送短信接口
                sms_code = random.randint(10000,99999)
                # 重點 重點 重點?。。。。。?!
                result = mail.delay(mobile,sms_code,1)
               # 加入短信嗎發(fā)送成功
                if result:
                    # redis中要存短信驗證嗎
                    conn.setex(mobile,60,sms_code)
                    # 把圖片驗證碼從redis中刪除
                    conn.delete(uuid)
                    return Response({'msg':sms_code})
                else:
                    return ({'msg':'發(fā)送失敗'})
            else:
                return Response({'msg':'驗證碼不正確'})
        return Response('ok')

6 .先啟動django項目 然后另開終端 cd到項目

目錄下啟動celery 服務 指定并發(fā)數 --autoscale(最多,最少)

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

以上就是Django使用celery異步發(fā)送短信驗證碼代碼示例的詳細內容,更多關于Django使用celery異步發(fā)送短信驗證碼的資料請關注腳本之家其它相關文章!

相關文章

  • PyTorch搭建LSTM實現時間序列負荷預測

    PyTorch搭建LSTM實現時間序列負荷預測

    這篇文章主要為大家介紹了PyTorch搭建LSTM實現時間序列負荷預測,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-05-05
  • python3獲取視頻文件播放時長的三種方法

    python3獲取視頻文件播放時長的三種方法

    這篇文章主要介紹了python3獲取視頻文件播放時長的三種方法,VideoFileClip,CV2以及FFmpeg這三種方法,文章通過代碼示例給大家講解的非常詳細,需要的朋友可以參考下
    2024-04-04
  • Python防止SQL注入攻擊的方法

    Python防止SQL注入攻擊的方法

    本文介紹了Python開發(fā)中防止SQL注入攻擊,包括使用參數化查詢、利用ORM框架如Django和SQLAlchemy,確保用戶輸入的安全,感興趣的可以了解一下
    2025-07-07
  • Python基于數列實現購物車程序過程詳解

    Python基于數列實現購物車程序過程詳解

    這篇文章主要介紹了Python基于數列實現購物車程序過程詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-06-06
  • Python Numpy庫安裝與基本操作示例

    Python Numpy庫安裝與基本操作示例

    這篇文章主要介紹了Python Numpy庫安裝與基本操作,簡單介紹了Numpy庫的基本功能、并結合實例形式分析了基于Numpy庫的數組與矩陣相關操作技巧,需要的朋友可以參考下
    2019-01-01
  • pandas 缺失值與空值處理的實現方法

    pandas 缺失值與空值處理的實現方法

    這篇文章主要介紹了pandas 缺失值與空值處理的實現方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2019-10-10
  • python通過索引遍歷列表的方法

    python通過索引遍歷列表的方法

    這篇文章主要介紹了python通過索引遍歷列表的方法,實例分析了Python遍歷列表的相關技巧,非常具有實用價值,需要的朋友可以參考下
    2015-05-05
  • pandas如何修改DataFrame行/列/字段值

    pandas如何修改DataFrame行/列/字段值

    這篇文章主要介紹了pandas如何修改DataFrame行/列/字段值問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-08-08
  • Django使用 Bootstrap 樣式修改書籍列表過程解析

    Django使用 Bootstrap 樣式修改書籍列表過程解析

    這篇文章主要介紹了Django使用 Bootstrap 樣式修改書籍列表過程解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-08-08
  • python代碼實現AVL樹和紅黑樹

    python代碼實現AVL樹和紅黑樹

    專注于Python數據結構,想要深入了解AVL樹和紅黑樹的讀者們,你們的機會來了!在這篇指南中,我們將帶你探索這兩種神奇樹結構的奧秘,緊張刺激的實戰(zhàn)代碼演示,讓你一窺這兩種樹的獨特魅力,準備好了嗎?讓我們一起踏上這場Python樹結構之旅!
    2023-12-12

最新評論

浮梁县| 济源市| 宾川县| 望都县| 江津市| 平乐县| 拜城县| 准格尔旗| 德保县| 奎屯市| 江陵县| 信宜市| 留坝县| 长治县| 安图县| 麦盖提县| 仙游县| 琼中| 乌拉特前旗| 宿州市| 江孜县| 调兵山市| 马尔康县| 仙游县| 延川县| 襄垣县| 长白| 固原市| 永仁县| 五寨县| 眉山市| 鞍山市| 弥勒县| 香港 | 石嘴山市| 孟津县| 南部县| 托克逊县| 胶州市| 阜南县| 汤阴县|