zoukankan      html  css  js  c++  java
  • Django之使用celery异步完成发送验证码

    使用celery的目的:将项目中耗时的操作放入一个新的进程实现

    1.安装celery

    pip install celery

    2.在项目的文件夹下创建包celery_tasks用于保存celery异步任务

    3.在celery_tasks下新建config.py===>指定broker到redis

    broker_url='redis://127.0.0.1:6379/15'

    4.在celery_tasks包下创建main.py文件,用于作为celery的启动文件

    from celery import Celery
    
    # 为celery使用django配置文件进行设置
    import os
    if not os.getenv('DJANGO_SETTINGS_MODULE'):
        os.environ['DJANGO_SETTINGS_MODULE'] = 'xiangmu_api.settings'
    
    # 创建celery应用
    app = Celery('xiangmu')
    
    # 导入celery配置
    app.config_from_object('celery_tasks.config')
    
    # 自动注册celery任务
    app.autodiscover_tasks(['celery_tasks.sms'])

    5.在celery_tasks/sms/包下创建tasks.py文件,用于保存发送短信的异步任务

    6.在tasks.py中定义函数:加装饰器@app.task(name="")

    import logging
    
    from celery_tasks.main import app
    from utils.ytx_sdk.sendSMS import CCP
    
    logger = logging.getLogger("django")
    
    
    @app.task(name='send_sms_code')
    def send_sms_code(mobile, code, expires, template_id):
        """
        发送短信验证码
        :param mobile: 手机号
        :param code: 验证码
        :param expires: 有效期
        :return: None
        """
    
        try:
            # result = CCP.send_template_sms(mobile, [code, expires], template_id)
            result = 0
            print(code)
        except Exception as e:
            logger.error("发送验证码短信[异常][ mobile: %s, message: %s ]" % (mobile, e))
        else:
            if result == 0:
                logger.info("发送验证码短信[正常][ mobile: %s ]" % mobile)
            else:
                logger.warning("发送验证码短信[失败][ mobile: %s ]" % mobile)

    7.在views.py中使用celery,语法:任务函数.delay(参数)

    send_sms_code.delay(mobile,sms_code,sms_code_expires,1)

    8.在项目目录下启动celery

    celery -A celery_tasks.main worker -l info
  • 相关阅读:
    解析SQL Server之任务调度
    Sqlserver (转载)事物与锁
    浅谈SQL Server数据内部表现形式
    浅谈SQL Server事务与锁(上篇)
    如何查看某个查询用了多少TempDB空间
    Select count(*)和Count(1)的区别和执行方式
    zookeeper 源码(二) session 和 处理事务请求
    zookeeper 源码(一) 选举和同步数据
    分布式一致性协议 --- Paxos
    分布式事务 --- 2PC 和 3PC
  • 原文地址:https://www.cnblogs.com/xiaolu915/p/10516713.html
Copyright © 2011-2022 走看看