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"})
  • 相关阅读:
    MyBatis(十)插件开发 之 插件运行原理
    通用Mapper(二)使用通用 Mapper
    通用Mapper(十四)通用Mapper接口大全
    通用Mapper(十三)通用Mapper原理
    通用Mapper(十二)通用Mapper配置项
    通用Mapper(十)二级缓存
    通用Mapper(九)通用 Mapper 接口扩展
    Linux安装与部署SonarQube
    Sonarqube分析代码并导出PDF分析报告
    SVN update失败,cleanup后再update
  • 原文地址:https://www.cnblogs.com/qq128/p/13749734.html
Copyright © 2011-2022 走看看