Python Celery異步任務(wù)隊(duì)列使用方法解析
Celery是一個(gè)異步的任務(wù)隊(duì)列(也叫做分布式任務(wù)隊(duì)列),一個(gè)簡單,靈活,可靠的分布式系統(tǒng),用于處理大量消息,同時(shí)為操作提供維護(hù)此類系統(tǒng)所需要的工具。
celery的優(yōu)點(diǎn)
1:簡單,容易使用,不需要配置文件
2:高可用,任務(wù)執(zhí)行失敗或執(zhí)行過程中發(fā)生連續(xù)中斷,celery會(huì)自動(dòng)嘗試重新執(zhí)行任務(wù)
3:快速,一個(gè)單進(jìn)程的celery每分鐘可以處理上百萬個(gè)任務(wù)
4:靈活,幾乎celery的各個(gè)組件都可以被擴(kuò)展
celery應(yīng)用場景
1:異步發(fā)郵件,一般發(fā)郵件等比較耗時(shí)的操作,這個(gè)時(shí)候需要提交任務(wù)給celery就可以了,由worker進(jìn)行發(fā)郵件操作
2:有些跑批量接口任務(wù),需要耗時(shí)較長,也可以做成異步任務(wù)
3:定時(shí)調(diào)度任務(wù)
Celery與Django一起使用(以發(fā)送短信為例)
獨(dú)立于項(xiàng)目新建一個(gè)package包
在package包中新建一個(gè)名為sms的package包
新建tasks.py文件
#定義耗時(shí)的函數(shù)from utils.ytx_sdk.sendSMS import CCPfrom celery_tasks.main import app#為函數(shù)添加裝飾器,這個(gè)函數(shù)就成為了celery的任務(wù)@app.taskdef send_sms_code(mobile,code,expires,template_id): try: # CCP.sendTemplateSMS(mobile,code,expires,template_id) print(code) except: return ’發(fā)送短信失敗’
在package包中新建config.py
內(nèi)容如下(中間人,接收生產(chǎn)者發(fā)來的消息即Task,將任務(wù)存入隊(duì)列。任務(wù)的消費(fèi)者是Worker。Celery本身不提供隊(duì)列服務(wù),推薦用Redis或RabbitMQ實(shí)現(xiàn)隊(duì)列服務(wù)。)
#指定代理人隊(duì)列==>redisbroker_url=’redis://127.0.0.1:6379/15’
在package包中新建main.py
內(nèi)容如下(需要將task注冊到celery應(yīng)用中)
#啟動(dòng)工人的文件from celery import Celery# 為celery使用django配置文件進(jìn)行設(shè)置import osif not os.getenv(’DJANGO_SETTINGS_MODULE’): os.environ[’DJANGO_SETTINGS_MODULE’] = ’yinyue.settings.dev’# 創(chuàng)建celery應(yīng)用app = Celery(’yinyue’)# 導(dǎo)入celery配置app.config_from_object(’celery_tasks.config’)# 自動(dòng)注冊celery任務(wù)app.autodiscover_tasks([ ’celery_tasks.sms’])
在django框架對應(yīng)模塊的視圖中使用
#調(diào)用celery的任務(wù):任務(wù)名.delay(參數(shù))send_sms_code.delay(mobile,code,constants.SMS_CODE_EXPIRES/60,1)
啟動(dòng)celery服務(wù): celery -A celery_tasks.main worker -l info
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. js實(shí)現(xiàn)碰撞檢測2. 一文帶你徹底理解Java序列化和反序列化3. JS實(shí)現(xiàn)前端動(dòng)態(tài)分頁碼代碼實(shí)例4. 關(guān)于IDEA 2020.3 多窗口視圖丟失的問題5. PHP驗(yàn)證碼工具-Securimage6. 用Spring JMS使異步消息變得簡單7. 通過實(shí)例解析Python文件操作實(shí)現(xiàn)步驟8. Python3 json模塊之編碼解碼方法講解9. Python 制作查詢商品歷史價(jià)格的小工具10. Python 解析庫json及jsonpath pickle的實(shí)現(xiàn)

網(wǎng)公網(wǎng)安備