資訊專(zhuān)欄INFORMATION COLUMN
摘要：介紹應(yīng)用舉例是一個(gè)基于開(kāi)發(fā)的分布式異步消息任務(wù)隊(duì)列，通過(guò)它可以輕松的實(shí)現(xiàn)任務(wù)的異步處理，如果你的業(yè)務(wù)場(chǎng)景中需要用到異步任務(wù)，就可以考慮使用你想對(duì)臺(tái)機(jī)器執(zhí)行一條批量命令，可能會(huì)花很長(zhǎng)時(shí)間，但你不想讓你的程序等著結(jié)果返回，
分布式異步消息任務(wù)隊(duì)列，通過(guò)它可以輕松的實(shí)現(xiàn)任務(wù)的異步處理，如果你的業(yè)務(wù)場(chǎng)景中需要用到異步任務(wù)，就可以考慮使用celery
from __future__ import absolute_import, unicode_literalsimport osfrom celery import Celery# 設(shè)置環(huán)境變量os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo.settings")# 注冊(cè)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()
CELERY_BROKER_URL = "redis://127.0.0.1:6379/"CELERY_RESULT_BACKEND = "redis://127.0.0.1:6379/"CELERY_RESULT_SERIALIZER = "json"
from __future__ import absolute_import, unicode_literalsfrom .celery import app as celery_app__all__ = ["celery_app"]
from celery.task import taskfrom .comm import send_message# 定義發(fā)送郵件的方法@taskdef mail(mobile,code): send_message(mobile,code,5)
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":"沒(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")
指定并發(fā)數(shù) --autoscale(最多,最少)
celery worker -A meiduo --loglevel=info --pool=solo --autoscale=50,5
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/118794.html
小編寫(xiě)這篇文章的主要目的，主要是給大家去進(jìn)行講解Django項(xiàng)目實(shí)例情況，包括celery的一些具體使用情況介紹，學(xué)習(xí)這些的話，對(duì)我們的工作和生活幫助還是很大的，但是怎么樣才能夠更快的進(jìn)行上手呢？下面就一個(gè)具體實(shí)例給大家進(jìn)行解答?！ ?、django應(yīng)用Celery django框架請(qǐng)求/響應(yīng)的過(guò)程是同步的，框架本身無(wú)法實(shí)現(xiàn)異步響應(yīng)?！ 〉俏覀?cè)陧?xiàng)目過(guò)程中會(huì)經(jīng)常會(huì)遇到一些耗時(shí)的任務(wù),比如：...
摘要：結(jié)論執(zhí)行完任務(wù)不釋放內(nèi)存與原一直沒(méi)有被銷(xiāo)毀有關(guān)，因此可以適當(dāng)配置小點(diǎn)，而任務(wù)并發(fā)數(shù)與配置項(xiàng)有關(guān)，每增加一個(gè)必然增加內(nèi)存消耗，同時(shí)也影響到一個(gè)何時(shí)被銷(xiāo)毀，因?yàn)槭蔷鶆蛘{(diào)度任務(wù)至每個(gè)，因此也不宜配置過(guò)大，適當(dāng)配置。 1.實(shí)際使用 ? 監(jiān)控task的執(zhí)行結(jié)果：任務(wù)id，結(jié)果，traceback，children，任務(wù)狀態(tài) ? 配置 backend=redis://127...
摘要：中常用的幾個(gè)框架有等，今天來(lái)總結(jié)一下和的不同。本文使用的環(huán)境是。文件可以加載路由信息和項(xiàng)目配置信息，文件負(fù)責(zé)啟動(dòng)項(xiàng)目。以上就簡(jiǎn)單的比較了和幾個(gè)方面的不同，它們各有優(yōu)缺點(diǎn)，實(shí)際工作中可以根據(jù)不同的需求選擇不同的框架進(jìn)行開(kāi)發(fā)。 python中常用的幾個(gè)web框架有django, tornado, flask等，今天來(lái)總結(jié)一下django和tornado的不同。工作中django和torna...
摘要：在這里的腳本有，部署到預(yù)發(fā)布生產(chǎn)服務(wù)器，清理目錄，壓縮，備份數(shù)據(jù)庫(kù)，在本地，等等。目錄存儲(chǔ)了所有數(shù)據(jù)庫(kù)，，，，等等的配置文件。我使用做所有的排序任務(wù)，從發(fā)送郵件到從拉取數(shù)據(jù)。當(dāng)我第一次開(kāi)始開(kāi)發(fā)和的時(shí)候，我使用，但是已經(jīng)把所有事情移植進(jìn)了。 本文原文是 11 Things I Wish I Knew About Django Development Before I Star...
閱讀 1568·2021-09-22 15:52
閱讀 3474·2021-09-22 14:59
閱讀 2857·2021-09-02 15:12
閱讀 982·2021-08-20 09:35
閱讀 1590·2019-08-30 14:09
閱讀 2719·2019-08-30 13:56
閱讀 1661·2019-08-26 18:27
閱讀 3373·2019-08-26 13:37
