python中使用Celery容联云异步发送验证码功能
更新时间:2021年9月2日 12:00 点击:1302
1.celery异步消息队列介绍
celery应用举例
- Celery 是一个 基于python开发的分布式异步消息任务队列,通过它可以轻松的实现任务的异步处理,如果你的业务场景中需要用到异步任务,就可以考虑使用celery
- 你想对100台机器执行一条批量命令,可能会花很长时间 ,但你不想让你的程序等着结果返回,而是给你返回 一个任务ID,你过一段时间只需要拿着这个任务id就可以拿到任务执行结果, 在任务执行ing进行时,你可以继续做其它的事情
- Celery 在执行任务时需要通过一个消息中间件来接收和发送任务消息,以及存储任务结果, 一般使用rabbitMQ or Redis
Celery有以下优点
- 简单:一单熟悉了celery的工作流程后,配置和使用还是比较简单的
- 高可用:当任务执行失败或执行过程中发生连接中断,celery 会自动尝试重新执行任务
- 快速:一个单进程的celery每分钟可处理上百万个任务
- 灵活: 几乎celery的各个组件都可以被扩展及自定制
Celery 特性
- 方便查看定时任务的执行情况, 如 是否成功, 当前状态, 执行任务花费的时间等.
- 可选 多进程, Eventlet 和 Gevent 三种模型并发执行.
- Celery 是语言无关的.它提供了python 等常见语言的接口支持.
2.工作原理 *****
Celery 扮演生产者和消费者的角色
- Celery Beat : 任务调度器. Beat 进程会读取配置文件的内容, 周期性的将配置中到期需要执行的任务发送给任务队列.
- Celery Worker : 执行任务的消费者, 通常会在多台服务器运行多个消费者, 提高运行效率.
- Broker : 消息代理, 队列本身. 也称为消息中间件. 接受任务生产者发送过来的任务消息, 存进队列再按序分发给任务消费方(通常是消息队列或者数据库).
- Producer : 任务生产者. 调用 Celery API , 函数或者装饰器, 而产生任务并交给任务队列处理的都是任务生产者.
- Result Backend : 任务处理完成之后保存状态信息和结果, 以供查询.
思维导图
3.异步发短信
首先得安装俩个表要包
pip install celery pip install celery-with-redis
3.1.settings同级目录下创建 celery 文件
如果 'namespace=‘CELERY''出现报错 celery可以适当降一下级别 ‘4.4.7'
from __future__ import absolute_import, unicode_literals import os from celery import Celery # 设置环境变量 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'md.settings') # 注册Celery的APP app = Celery('meiduo') # 绑定配置文件 app.config_from_object('django.conf:settings', namespace='CELERY') # 自动发现各个app下的tasks.py文件 # app.autodiscover_tasks()
3.2.redis及容联云配置
#获取redis连接 def getRedis(): from django_redis import get_redis_connection conn = get_redis_connection() return conn #发短信 去容联云官网查找自己的信息 from ronglian_sms_sdk import SmsSDK accId = 'ACCOUNT SID(主账号ID)' accToken = 'AUTH TOKEN(账户授权令牌)' appId = 'AppID(默认)' import json def send_message(mobile,code,time): sdk = SmsSDK(accId, accToken, appId) tid = '1' datas = (code, time) resp = sdk.sendMessage(tid, mobile, datas) result = json.loads(resp) if result['statusCode'] == '000000': return 1 return 2
3.3.配置settings文件
CELERY_BROKER_URL = 'redis://127.0.0.1:6379/' CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/' CELERY_RESULT_SERIALIZER = 'json'
3.4.配置 settings同级目录下 init 文件
from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ['celery_app']
3.5.在utils下新建一个task.py文件
# 写异步任务的地方 from celery.task import task from .comm import send_message # 定义发送手机号的方法 @task def mail(mobile,code,time): send_message(mobile,code,time)
3.6.接口中调用
如果用了redis数据库,得先开启数据库
from utils.task import send_message from utils.comm import getRedis import random class SendMes(APIView): # 短信验证 def get(self,request): # 接收客户端发送的数据 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':'没有获取到'}) # 验证图片验证码 conn =getRedis() # redis 中取验证码 code = conn.get(uuid) print(code) if code: code = str(code,encoding='utf8') # 图片验证码对比 if imagecode.lower() == code.lower(): # 验证通过后调用发送短信接口 sms_code = random.randint(10000,99999) # 引用comm文件中的send_message result = send_message(mobile,sms_code,1) # 加入短信吗发送成功 if result: # redis中要存短信验证吗 conn.setex(mobile,60,sms_code) # 把图片验证码从redis中删除 conn.delete(uuid) return Response({'msg':sms_code}) else: return ({'msg':'发送失败'}) else: return Response({'msg':'验证码不正确'}) return Response('ok')
3.7.先启动django项目
然后另开终端 cd到项目 目录下启动celery 服务
指定并发数 --autoscale(最多,最少)
celery worker -A 项目的文件名 --loglevel=info --pool=solo --autoscale=50,5 urn Response('ok') ~~~ #### 3.7.先启动django项目 然后另开终端 cd到项目 目录下启动celery 服务 指定并发数 --autoscale(最多,最少) ```pyhon celery worker -A 项目的文件名 --loglevel=info --pool=solo --autoscale=50,5
到此这篇关于使用Celery 容联云 异步发送验证码的文章就介绍到这了,更多相关Celery异步发送验证码内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
- 最近想自学PHP ,做了个验证码,但不知道怎么搞的,总出现一个如下图的小红叉,但验证码就是显示不出来,原因如下 未修改之前,出现如下错误; (1)修改步骤如下,原因如下,原因是apache权限没开, (2)点击打开php.int., 搜索extension=ph...2013-10-04
jQuery Real Person验证码插件防止表单自动提交
本文介绍的jQuery插件有点特殊,防自动提交表单的验证工具,就是我们经常用到的验证码工具,先给大家看看效果。效果图如下: 使用说明 需要使用jQuery库文件和Real Person库文件 同时需要自定义验证码显示的CSS样式 使用实例...2015-11-08- 这篇文章主要为大家详细介绍了JS实现随机生成验证码,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-06
- 这篇文章主要介绍了C#中异步和多线程的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2021-01-16
- 多线程和异步操作两者都可以达到避免调用线程阻塞的目的,从而提高软件的可响应性。甚至有些时候我们就认为多线程和异步操作是等同的概念。但是,多线程和异步操作还是有一些区别的。而这些区别造成了使用多线程和异步操作的时机的区别...2020-06-25
- 通过jquery.cookie.js插件可以快速实现“点击获取验证码后60秒内禁止重新获取(防刷新)”的功能效果图:先到官网(http://plugins.jquery.com/cookie/)下载cookie插件,放到相应文件夹,代码如下:复制代码 代码如下: <!DOCTYPE ht...2015-03-15
- 本篇文章主要介绍了C# Socket异步通信,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25
- 验证码类文件 CreateImg.class.php <?php class ValidationCode { private $width,$height,$codenum; public $checkcode; //产生的验证码 private $checkimage; //验证码图片 private $disturbColor = ''; /...2015-11-08
- 这篇文章主要介绍了基于JavaScript实现验证码功能的相关资料...2017-04-03
- 这篇文章主要给大家介绍了关于JS异步的执行原理和回调的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-08
- 这篇文章主要给大家介绍了关于c# winform异步不卡界面的实现方法,文中通过示例代码介绍的非常详细,对大家学习或者使用c#具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧...2020-06-25
- 这篇文章主要介绍了JQuery基于FormData异步提交数据文件,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-09-02
- 下面小编就为大家带来一篇单击按钮发送验证码,出现倒计时的简单实例。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧 代码...2017-07-06
Bootstrap中文本框的宽度变窄并且加入一副验证码图片的实现方法
这篇文章主要介绍了Bootstrap中文本框的宽度变窄并且加入一副验证码图片的实现方法的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下...2016-06-24- 验证码是一个现在WEB2.0中常见的一个功能了,像注册、登录又或者是留言页面,都需要注册码来验证当前操作者的合法性,我们会看到有些网站没有验证码,但那是更高级的验证了,...2016-11-25
- 这篇文章主要介绍了基于Pytorch版yolov5的滑块验证码破解思路详解,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-02-25
- 最近接到新需求,需要实现一个点击发送验证码之后,按钮禁用,在5秒之后取消禁用,看似需求很简单,实现起来还真的好好动动脑筋,下面小编把jquery控制按钮禁用核心代码分享给大家,需要的朋友参考下吧...2021-07-24
- 工信部的ICP备案网站登录时验证码一直输入不正确怎么回事,为了防止一些机器采集人工信部对于查询验证做得识别度极低,所以许多的朋友都会发现输入验证码一直有问题了,那...2016-10-10
如何使用PHP+jQuery+MySQL实现异步加载ECharts地图数据(附源码下载)
ECharts地图主要用于地理区域数据的可视化,展示不同区域的数据分布信息,通过本文给大家介绍如何使用PHP+jQuery+MySQL实现异步加载ECharts地图数据,需要的朋友参考下吧...2016-02-26- web开发中,经常会使用验证码功能,例如登录、注册,或其他关键功能之前经常会使用。下面通过实例代码给大家介绍Web制作验证码功能实例代码,感兴趣的朋友一起看看吧...2017-06-24