Django使用celery異步發(fā)送短信驗(yàn)證碼代碼示例
celery
1.celery介紹
1.1 celery應(yīng)用舉例
- Celery 是一個(gè) 基于python開(kāi)發(fā)的分布式異步消息任務(wù)隊(duì)列，通過(guò)它可以輕松的實(shí)現(xiàn)任務(wù)的異步處理，如果你的業(yè)務(wù)場(chǎng)景中需要用到異步任務(wù)，就可以考慮使用celery
- 你想對(duì)100臺(tái)機(jī)器執(zhí)行一條批量命令，可能會(huì)花很長(zhǎng)時(shí)間 ，但你不想讓你的程序等著結(jié)果返回，而是給你返回 一個(gè)任務(wù)ID,你過(guò)一段時(shí)間只需要拿著這個(gè)任務(wù)id就可以拿到任務(wù)執(zhí)行結(jié)果， 在任務(wù)執(zhí)行ing進(jìn)行時(shí)，你可以繼續(xù)做其它的事情
- Celery 在執(zhí)行任務(wù)時(shí)需要通過(guò)一個(gè)消息中間件來(lái)接收和發(fā)送任務(wù)消息，以及存儲(chǔ)任務(wù)結(jié)果， 一般使用rabbitMQ or Redis
1.2 Celery有以下優(yōu)點(diǎn)
簡(jiǎn)單：一單熟悉了celery的工作流程后，配置和使用還是比較簡(jiǎn)單的
高可用：當(dāng)任務(wù)執(zhí)行失敗或執(zhí)行過(guò)程中發(fā)生連接中斷，celery 會(huì)自動(dòng)嘗試重新執(zhí)行任務(wù)快速：一個(gè)單進(jìn)程的celery每分鐘可處理上百萬(wàn)個(gè)任務(wù)
靈活： 幾乎celery的各個(gè)組件都可以被擴(kuò)展及自定制
1.3 Celery 特性
方便查看定時(shí)任務(wù)的執(zhí)行情況, 如 是否成功, 當(dāng)前狀態(tài), 執(zhí)行任務(wù)花費(fèi)的時(shí)間等.
可選 多進(jìn)程, Eventlet 和 Gevent 三種模型并發(fā)執(zhí)行.
Celery 是語(yǔ)言無(wú)關(guān)的.它提供了python 等常見(jiàn)語(yǔ)言的接口支持.
2.工作原理
2.1 Celery 扮演生產(chǎn)者和消費(fèi)者的角色
Celery Beat : 任務(wù)調(diào)度器. Beat 進(jìn)程會(huì)讀取配置文件的內(nèi)容, 周期性的將配置中到期需要執(zhí)行的任務(wù)發(fā)送給任務(wù)隊(duì)列.
Celery Worker : 執(zhí)行任務(wù)的消費(fèi)者, 通常會(huì)在多臺(tái)服務(wù)器運(yùn)行多個(gè)消費(fèi)者, 提高運(yùn)行效率.
Broker : 消息代理, 隊(duì)列本身. 也稱為消息中間件. 接受任務(wù)生產(chǎn)者發(fā)送過(guò)來(lái)的任務(wù)消息, 存進(jìn)隊(duì)列再按序分發(fā)給任務(wù)消費(fèi)方(通常是消息隊(duì)列或者數(shù)據(jù)庫(kù)).
Producer : 任務(wù)生產(chǎn)者. 調(diào)用 Celery API , 函數(shù)或者裝飾器, 而產(chǎn)生任務(wù)并交給任務(wù)隊(duì)列處理的都是任務(wù)生產(chǎn)者.
Result Backend : 任務(wù)處理完成之后保存狀態(tài)信息和結(jié)果, 以供查詢.
3.異步發(fā)短信
1.settings同級(jí)目錄下創(chuàng)建 celery 文件
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# 設(shè)置環(huán)境變量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo.settings')
# 注冊(cè)Celery的APP
app = Celery('meiduo')
# 綁定配置文件
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自動(dòng)發(fā)現(xiàn)各個(gè)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同級(jí)目錄下 init 文件
from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ['celery_app']
4.在utils下新建一個(gè)task.py文件
from celery.task import task
from .comm import send_message
# 定義發(fā)送郵件的方法
@task
def mail(mobile,code):
send_message(mobile,code,5)
5.接口中調(diào)用
from utils.tasks import mail
import random
class SendMes(APIView):
# 短信驗(yàn)證
def get(self,request):
# 接收客戶端發(fā)送的數(shù)據(jù)
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':'沒(méi)有獲取到'})
# 驗(yàn)證圖片驗(yàn)證碼
conn =get_redis_conn()
# redis 中取驗(yàn)證碼
code = conn.get(uuid)
print(code)
if code:
code = str(code,encoding='utf8')
# 圖片驗(yàn)證碼對(duì)比
if imagecode.lower() == code.lower():
# 驗(yàn)證通過(guò)后調(diào)用發(fā)送短信接口
sms_code = random.randint(10000,99999)
# 重點(diǎn) 重點(diǎn) 重點(diǎn)！?。。。。?！
result = mail.delay(mobile,sms_code,1)
# 加入短信嗎發(fā)送成功
if result:
# redis中要存短信驗(yàn)證嗎
conn.setex(mobile,60,sms_code)
# 把圖片驗(yàn)證碼從redis中刪除
conn.delete(uuid)
return Response({'msg':sms_code})
else:
return ({'msg':'發(fā)送失敗'})
else:
return Response({'msg':'驗(yàn)證碼不正確'})
return Response('ok')
6 .先啟動(dòng)django項(xiàng)目 然后另開(kāi)終端 cd到項(xiàng)目
目錄下啟動(dòng)celery 服務(wù) 指定并發(fā)數(shù) --autoscale(最多,最少)
celery worker -A meiduo --loglevel=info --pool=solo --autoscale=50,5
以上就是Django使用celery異步發(fā)送短信驗(yàn)證碼代碼示例的詳細(xì)內(nèi)容，更多關(guān)于Django使用celery異步發(fā)送短信驗(yàn)證碼的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
pytorch使用過(guò)程中遇到的錯(cuò)誤處理之內(nèi)存溢出問(wèn)題
這篇文章主要介紹了pytorch使用過(guò)程中遇到的錯(cuò)誤處理之內(nèi)存溢出問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-09-09
這篇文章主要給大家介紹了關(guān)于如何利用Python批量處理多個(gè)txt文本的方法,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-10-10
python 創(chuàng)建一個(gè)空dataframe 然后添加行數(shù)據(jù)的實(shí)例
今天小編就為大家分享一篇python 創(chuàng)建一個(gè)空dataframe 然后添加行數(shù)據(jù)的實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-06-06
Python實(shí)現(xiàn)像awk一樣分割字符串
這篇文章主要介紹了Python實(shí)現(xiàn)像awk一樣分割字符串,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09
這篇文章主要為大家詳細(xì)介紹了pygame實(shí)現(xiàn)時(shí)鐘效果，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-06-06
Python3.0 實(shí)現(xiàn)決策樹(shù)算法的流程
這篇文章主要介紹了Python3.0 實(shí)現(xiàn)決策樹(shù)算法的流程，本文給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2019-08-08
python正則表達(dá)式match和search用法實(shí)例
這篇文章主要介紹了python正則表達(dá)式match和search用法,實(shí)例分析了正則表達(dá)式中match和search的功能、定義及相關(guān)使用技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03
今天小編就為大家分享一篇利用Python庫(kù)Scapy解析pcap文件的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2019-07-07
python 調(diào)用pyautogui 實(shí)時(shí)獲取鼠標(biāo)的位置、移動(dòng)鼠標(biāo)的方法
今天小編就為大家分享一篇python 調(diào)用pyautogui 實(shí)時(shí)獲取鼠標(biāo)的位置、移動(dòng)鼠標(biāo)的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2019-08-08
使用Pandas?實(shí)現(xiàn)MySQL日期函數(shù)的解決方法
這篇文章主要介紹了用Pandas?實(shí)現(xiàn)MySQL日期函數(shù)的效果,Python是很靈活的語(yǔ)言，達(dá)成同一個(gè)目標(biāo)或有多種途徑，我提供的只是其中一種解決方法，需要的朋友可以參考下2023-02-02