celery异步任务发送短信验证码

迈不过友情╰ 2022-05-12 08:46 240阅读 0赞

#### 1.在项目中创建celery\_tasks包 ####

#### 2.在celery\_tasks目录下创建config.py文件，用于保存celery的配置信息 ####

broker_url = "redis://127.0.0.1/14"

#### 3.在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'] = '项目的配置路径'
    
    # 创建celery应用
    app = Celery('随便起个名称')
    
    # 导入celery配置
    app.config_from_object('celery_tasks.config')
    
    # 自动注册celery任务
    app.autodiscover_tasks(['celery_tasks.sms'])

#### 4.在celery\_tasks目录下创建sms包，用于放置发送短信的异步任务相关代码 ####

#### 5.在celery\_tasks/sms/目录下创建tasks.py文件(文件名必须是tasks)，用于保存发送短信的异步任务 ####

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

#### 6.apps/users/views.py中改写SMSCodeView视图，使用celery异步任务发送短信 ####

class SMSCodeView(APIView):
    
    	def get(self, request, mobile):
    
    		...
    		# 发送短信
    		send_sms_code.delay(mobile, sms_code)
    
    		# 返回结果
    		return Response({ "message": "ok"})

#### 7.进入虚拟环境，切换到celery\_tasks文件夹路径下，开启异步 ####

celery -A celery_tasks.main worker -l info

参数解释：

*  \-A celery\_tasks.main 指定启动文件
 *  worker 创建任务执行者
 *  \-l info 查看详细执行过程