Python Celery异步任务队列使用方法解析
作者:Yi_warmth 时间:2023-05-18 02:34:53
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 CCP
from celery_tasks.main import app
#为函数添加装饰器,这个函数就成为了celery的任务
@app.task
def 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实现队列服务。)
#指定代理人队列==>redis
broker_url='redis://127.0.0.1:6379/15'
在package包中新建main.py
内容如下(需要将task注册到celery应用中)
#启动工人的文件
from celery import Celery
# 为celery使用django配置文件进行设置
import os
if 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
来源:https://www.cnblogs.com/zhouzetian/p/13380533.html
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
MySql分组后随机获取每组一条数据的操作
Golang验证器之validator是使用详解
![](https://img.aspxhome.com/file/2023/9/107319_0s.png)
使用AJAX和Django获取数据的方法实例
使用Python编写一个最基础的代码解释器的要点解析
![](https://img.aspxhome.com/file/2023/4/107974_0s.jpg)
详解Python AdaBoost算法的实现
![](https://img.aspxhome.com/file/2023/3/66843_0s.jpg)
Python实现识别XSS漏洞的方法详解
ASP.NET Core基础之Main方法讲解
Python使用Asyncio实现检查网站状态
pycharm创建并使用虚拟环境的详细图文教程
![](https://img.aspxhome.com/file/2023/8/120288_0s.png)
Pytorch中torch.stack()函数的深入解析
![](https://img.aspxhome.com/file/2023/9/115029_0s.png)
基于Python编写一个简单的垃圾邮件分类器
Vue3新属性之css中使用v-bind的方法(v-bind in css)
![](https://img.aspxhome.com/file/2023/1/123081_0s.jpg)
python中的unittest框架实例详解
python PyTorch参数初始化和Finetune
![](https://img.aspxhome.com/file/2023/4/75934_0s.png)
Python如何用str.format()批量生成网址(豆瓣读书为例)
![](https://img.aspxhome.com/file/2023/9/133229_0s.png)
Python列表(list)所有元素的同一操作解析
![](https://img.aspxhome.com/file/2023/1/121531_0s.png)
实际应用:MySQL5存储过程编写
JavaScript封装弹框插件的方法
![](https://img.aspxhome.com/file/2023/3/130283_0s.gif)
利用Python实现自动工作汇报的脚本分享
![](https://img.aspxhome.com/file/2023/8/128498_0s.png)