电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Python Celery異步任務隊列使用方法解析

瀏覽:7日期:2022-07-14 15:29:22

Celery是一個異步的任務隊列(也叫做分布式任務隊列),一個簡單,靈活,可靠的分布式系統,用于處理大量消息,同時為操作提供維護此類系統所需要的工具。

celery的優點

1:簡單,容易使用,不需要配置文件

2:高可用,任務執行失敗或執行過程中發生連續中斷,celery會自動嘗試重新執行任務

3:快速,一個單進程的celery每分鐘可以處理上百萬個任務

4:靈活,幾乎celery的各個組件都可以被擴展

celery應用場景

1:異步發郵件,一般發郵件等比較耗時的操作,這個時候需要提交任務給celery就可以了,由worker進行發郵件操作

2:有些跑批量接口任務,需要耗時較長,也可以做成異步任務

3:定時調度任務

Celery與Django一起使用(以發送短信為例)

獨立于項目新建一個package包

在package包中新建一個名為sms的package包

新建tasks.py文件

#定義耗時的函數from utils.ytx_sdk.sendSMS import CCPfrom celery_tasks.main import app#為函數添加裝飾器,這個函數就成為了celery的任務@app.taskdef send_sms_code(mobile,code,expires,template_id): try: # CCP.sendTemplateSMS(mobile,code,expires,template_id) print(code) except: return ’發送短信失敗’

在package包中新建config.py

內容如下(中間人,接收生產者發來的消息即Task,將任務存入隊列。任務的消費者是Worker。Celery本身不提供隊列服務,推薦用Redis或RabbitMQ實現隊列服務。)

#指定代理人隊列==>redisbroker_url=’redis://127.0.0.1:6379/15’

在package包中新建main.py

內容如下(需要將task注冊到celery應用中)

#啟動工人的文件from celery import Celery# 為celery使用django配置文件進行設置import osif not os.getenv(’DJANGO_SETTINGS_MODULE’): os.environ[’DJANGO_SETTINGS_MODULE’] = ’yinyue.settings.dev’# 創建celery應用app = Celery(’yinyue’)# 導入celery配置app.config_from_object(’celery_tasks.config’)# 自動注冊celery任務app.autodiscover_tasks([ ’celery_tasks.sms’])

在django框架對應模塊的視圖中使用

#調用celery的任務:任務名.delay(參數)send_sms_code.delay(mobile,code,constants.SMS_CODE_EXPIRES/60,1)

啟動celery服務: celery -A celery_tasks.main worker -l info

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 重庆LED显示屏_显示屏安装公司_重庆LED显示屏批发-彩光科技公司 重庆钣金加工厂家首页-专业定做监控电视墙_操作台 | 扬子叉车厂家_升降平台_电动搬运车|堆高车-扬子仓储叉车官网 | 仓储笼_仓储货架_南京货架_仓储货架厂家_南京货架价格低-南京一品仓储设备制造公司 | 仪器仪表网 - 永久免费的b2b电子商务平台 | 硫酸亚铁-聚合硫酸铁-除氟除磷剂-复合碳源-污水处理药剂厂家—长隆科技 | 天津仓储物流-天津电商云仓-天津云仓一件代发-博程云仓官网 | 上海三信|ph计|酸度计|电导率仪-艾科仪器 | 玖容气动液压设备有限公司-气液增压缸_压力机_增压机_铆接机_增压器 | 德州网站开发定制-小程序开发制作-APP软件开发-「两山开发」 | 济南货架定做_仓储货架生产厂_重型货架厂_仓库货架批发_济南启力仓储设备有限公司 | 护栏打桩机-打桩机厂家-恒新重工| 爆破器材运输车|烟花爆竹运输车|1-9类危险品厢式运输车|湖北江南专用特种汽车有限公司 | 液压压力机,液压折弯机,液压剪板机,模锻液压机-鲁南新力机床有限公司 | 电动葫芦|环链电动葫芦-北京凌鹰名优起重葫芦 | 水篦子|雨篦子|镀锌格栅雨水篦子|不锈钢排水篦子|地下车库水箅子—安平县云航丝网制品厂 | 酒吧霸屏软件_酒吧霸屏系统,酒吧微上墙,夜场霸屏软件,酒吧点歌软件,酒吧互动游戏,酒吧大屏幕软件系统下载 | 楼梯定制_楼梯设计施工厂家_楼梯扶手安装制作-北京凌步楼梯 | 氢氧化钾厂家直销批发-济南金昊化工有限公司 | 重庆波纹管|重庆钢带管|重庆塑钢管|重庆联进管道有限公司 | 铁盒_铁罐_马口铁盒_马口铁罐_铁盒生产厂家-广州博新制罐 | 杭州成人高考_浙江省成人高考网上报名 | 地图标注-手机导航电子地图如何标注-房地产商场地图标记【DiTuBiaoZhu.net】 | 低粘度纤维素|混凝土灌浆料|有机硅憎水粉|聚羧酸减水剂-南京斯泰宝 | 鲁尔圆锥接头多功能测试仪-留置针测试仪-上海威夏环保科技有限公司 | 压装机-卧式轴承轮轴数控伺服压装机厂家[铭泽机械] | POM塑料_PBT材料「进口」聚甲醛POM杜邦原料、加纤PBT塑料报价格找利隆塑料 | 首页|光催化反应器_平行反应仪_光化学反应仪-北京普林塞斯科技有限公司 | 高扬程排污泵_隔膜泵_磁力泵_节能自吸离心水泵厂家-【上海博洋】 | 水质监测站_水质在线分析仪_水质自动监测系统_多参数水质在线监测仪_水质传感器-山东万象环境科技有限公司 | 示波器高压差分探头-国产电流探头厂家-南京桑润斯电子科技有限公司 | 流量检测仪-气密性检测装置-密封性试验仪-东莞市奥图自动化科技有限公司 | 台湾阳明固态继电器-奥托尼克斯光电传感器-接近开关-温控器-光纤传感器-编码器一级代理商江苏用之宜电气 | 常州减速机_减速机厂家_常州市减速机厂有限公司 | 土壤养分检测仪_肥料养分检测仪_土壤水分检测仪-山东莱恩德仪器 大型多片锯,圆木多片锯,方木多片锯,板材多片锯-祥富机械有限公司 | 合肥仿石砖_合肥pc砖厂家_合肥PC仿石砖_安徽旭坤建材有限公司 | 膜结构车棚|上海膜结构车棚|上海车棚厂家|上海膜结构公司 | 玉米深加工设备|玉米加工机械|玉米加工设备|玉米深加工机械-河南成立粮油机械有限公司 | 植筋胶-粘钢胶-碳纤维布-碳纤维板-环氧砂浆-加固材料生产厂家-上海巧力建筑科技有限公司 | 冷热冲击试验箱_温度冲击试验箱价格_冷热冲击箱排名_林频厂家 | 济南网站建设|济南建网站|济南网站建设公司【济南腾飞网络】【荐】 | 外贮压-柜式-悬挂式-七氟丙烷-灭火器-灭火系统-药剂-价格-厂家-IG541-混合气体-贮压-非贮压-超细干粉-自动-灭火装置-气体灭火设备-探火管灭火厂家-东莞汇建消防科技有限公司 |