国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

Django下使用celery 異步發(fā)送短信驗(yàn)證碼

everfly / 2842人閱讀

摘要:介紹應(yīng)用舉例是一個(gè)基于開發(fā)的分布式異步消息任務(wù)隊(duì)列,通過它可以輕松的實(shí)現(xiàn)任務(wù)的異步處理,如果你的業(yè)務(wù)場景中需要用到異步任務(wù),就可以考慮使用你想對臺機(jī)器執(zhí)行一條批量命令,可能會花很長時(shí)間,但你不想讓你的程序等著結(jié)果返回,

?

celery

1.celery介紹

1.1 celery應(yīng)用舉例

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

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

  • 簡單:一單熟悉了celery的工作流程后,配置和使用還是比較簡單的
  • 高可用:當(dāng)任務(wù)執(zhí)行失敗或執(zhí)行過程中發(fā)生連接中斷,celery 會自動(dòng)嘗試重新執(zhí)行任務(wù)
  • 快速:一個(gè)單進(jìn)程的celery每分鐘可處理上百萬個(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 是語言無關(guān)的.它提供了python 等常見語言的接口支持.

2.工作原理

2.1 Celery 扮演生產(chǎn)者和消費(fèi)者的角色

  • Celery Beat : 任務(wù)調(diào)度器. Beat 進(jìn)程會讀取配置文件的內(nèi)容, 周期性的將配置中到期需要執(zhí)行的任務(wù)發(fā)送給任務(wù)隊(duì)列.
  • Celery Worker : 執(zhí)行任務(wù)的消費(fèi)者, 通常會在多臺服務(wù)器運(yùn)行多個(gè)消費(fèi)者, 提高運(yùn)行效率.
  • Broker : 消息代理, 隊(duì)列本身. 也稱為消息中間件. 接受任務(wù)生產(chǎn)者發(fā)送過來的任務(wù)消息, 存進(jìn)隊(duì)列再按序分發(fā)給任務(wù)消費(fèi)方(通常是消息隊(duì)列或者數(shù)據(jù)庫).
  • 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同級目錄下創(chuàng)建 celery 文件

from __future__ import absolute_import, unicode_literalsimport osfrom celery import Celery# 設(shè)置環(huán)境變量os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo.settings")# 注冊Celery的APPapp = 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同級目錄下 init 文件

from __future__ import absolute_import, unicode_literalsfrom .celery import app as celery_app__all__ = ["celery_app"]

4.在utils下新建一個(gè)task.py文件

from celery.task import taskfrom .comm import send_message# 定義發(fā)送郵件的方法@taskdef mail(mobile,code):    send_message(mobile,code,5)    

5.接口中調(diào)用

from utils.tasks import mailimport randomclass 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":"沒有獲取到"})        # 驗(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)證碼對比            if imagecode.lower() == code.lower():                # 驗(yàn)證通過后調(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)目 然后另開終端 cd到項(xiàng)目 目錄下啟動(dòng)celery 服務(wù)

指定并發(fā)數(shù) --autoscale(最多,最少)

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

文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址:http://specialneedsforspecialkids.com/yun/118794.html

相關(guān)文章

  • Djangocelery使用項(xiàng)目實(shí)例

      小編寫這篇文章的主要目的,主要是給大家去進(jìn)行講解Django項(xiàng)目實(shí)例情況,包括celery的一些具體使用情況介紹,學(xué)習(xí)這些的話,對我們的工作和生活幫助還是很大的,但是怎么樣才能夠更快的進(jìn)行上手呢?下面就一個(gè)具體實(shí)例給大家進(jìn)行解答。  1、django應(yīng)用Celery  django框架請求/響應(yīng)的過程是同步的,框架本身無法實(shí)現(xiàn)異步響應(yīng)。  但是我們在項(xiàng)目過程中會經(jīng)常會遇到一些耗時(shí)的任務(wù),比如:...

    89542767 評論0 收藏0
  • Celery實(shí)際使用與內(nèi)存泄漏問題(面試)

    摘要:結(jié)論執(zhí)行完任務(wù)不釋放內(nèi)存與原一直沒有被銷毀有關(guān),因此可以適當(dāng)配置小點(diǎn),而任務(wù)并發(fā)數(shù)與配置項(xiàng)有關(guān),每增加一個(gè)必然增加內(nèi)存消耗,同時(shí)也影響到一個(gè)何時(shí)被銷毀,因?yàn)槭蔷鶆蛘{(diào)度任務(wù)至每個(gè),因此也不宜配置過大,適當(dāng)配置。 1.實(shí)際使用 ? 監(jiān)控task的執(zhí)行結(jié)果:任務(wù)id,結(jié)果,traceback,children,任務(wù)狀態(tài) ? 配置 backend=redis://127...

    0x584a 評論0 收藏0
  • django開發(fā)-django和tornado的不同

    摘要:中常用的幾個(gè)框架有等,今天來總結(jié)一下和的不同。本文使用的環(huán)境是。文件可以加載路由信息和項(xiàng)目配置信息,文件負(fù)責(zé)啟動(dòng)項(xiàng)目。以上就簡單的比較了和幾個(gè)方面的不同,它們各有優(yōu)缺點(diǎn),實(shí)際工作中可以根據(jù)不同的需求選擇不同的框架進(jìn)行開發(fā)。 python中常用的幾個(gè)web框架有django, tornado, flask等,今天來總結(jié)一下django和tornado的不同。工作中django和torna...

    Reducto 評論0 收藏0
  • 關(guān)于 Django 開發(fā)的 11 件事

    摘要:在這里的腳本有,部署到預(yù)發(fā)布生產(chǎn)服務(wù)器,清理目錄,壓縮,備份數(shù)據(jù)庫,在本地,等等。目錄存儲了所有數(shù)據(jù)庫,,,,等等的配置文件。我使用做所有的排序任務(wù),從發(fā)送郵件到從拉取數(shù)據(jù)。當(dāng)我第一次開始開發(fā)和的時(shí)候,我使用,但是已經(jīng)把所有事情移植進(jìn)了。 本文原文是 11 Things I Wish I Knew About Django Development Before I Star...

    JayChen 評論0 收藏0

發(fā)表評論

0條評論

最新活動(dòng)
閱讀需要支付1元查看
<