zoukankan      html  css  js  c++  java
  • celery

    使用Celery完成发送短信

     

    meiduo/meiduo_mall下创建celery_tasks用于保存celery异步任务。

    在celery_tasks目录下创建config.py文件,用于保存celery的配置信息

    broker_url = "redis://127.0.0.1/14"
    

    在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'] = 'meiduo_mall.settings.dev'
    
    # 创建celery应用
    app = Celery('meiduo')
    
    # 导入celery配置
    app.config_from_object('celery_tasks.config')
    
    # 自动注册celery任务
    app.autodiscover_tasks(['celery_tasks.sms'])
    

    在celery_tasks目录下创建sms目录,用于放置发送短信的异步任务相关代码。

    将提供的发送短信的云通讯SDK放到celery_tasks/sms/目录下。

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

    import logging
    
    from celery_tasks.main import app
    from .yuntongxun.sms import CCP
    
    logger = logging.getLogger("django")
    
    # 验证码短信模板
    SMS_CODE_TEMP_ID = 1
    
    @app.task(name='send_sms_code')
    def send_sms_code(mobile, code, expires):
        """
        发送短信验证码
        :param mobile: 手机号
        :param code: 验证码
        :param expires: 有效期
        :return: None
        """
    
        try:
            ccp = CCP()
            result = ccp.send_template_sms(mobile, [code, expires], SMS_CODE_TEMP_ID)
        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)
    

    在verifications/views.py中改写SMSCodeView视图,使用celery异步任务发送短信

    from celery_tasks.sms import tasks as sms_tasks
    
    class SMSCodeView(GenericAPIView):
        ...
            # 发送短信验证码
            sms_code_expires = str(constants.SMS_CODE_REDIS_EXPIRES // 60)
            sms_tasks.send_sms_code.delay(mobile, sms_code, sms_code_expires)
    
            return Response({"message": "OK"})
  • 相关阅读:
    2019年Pycharm最新激活码_学生党适用
    Day14_分享昨天看到的一句话
    监督学习算法_k-近邻(kNN)分类算法_源代码
    Python学习需要安装的工具
    Python基础学习资料推荐
    总结一下公司项目使用各种较新的前端技术和 Api 的一些经验。
    由 Session 和 Cookie 的区别说起
    我理解的正确的代码
    回忆我是如何赢得一次踢毽子比赛
    日常的例子说明 throttle 和 debounce 的区别
  • 原文地址:https://www.cnblogs.com/qq128/p/13749734.html
Copyright © 2011-2022 走看看