使用celery队列执行发送短信验证码

安装pip install -U Celery

from celery import Celery

# 创建celery实例
celery_app = Celery('meiduo')
# 添加消息队列（中间人broker）
celery_app.config_from_object('celery_tasks.config')
# 添加celery任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])

from celery_tasks.main import celery_app
from celery_tasks.sms.yuntongxun.ccp_sms import CCP
from celery_tasks.sms import constants


@celery_app.task(name='send_sms_code')
def send_sms_code(mobile, sms_code):
    """

    :param self:
    :param mobile:
    :param sms_code:
    :return:
    """

    send_ret = CCP().send_template_sms(mobile, [sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60],
                                       constants.SEND_SMS_TEMPLATE_ID)
    return send_ret
    

        # 使用celery发送短信验证码：from celery_tasks.sms.tasks import send_sms_code
        send_sms_code.delay(mobile, sms_code)

terminal中虚拟环境下meiduo_mall路径中执行语句：celery -A celery_tasks.main worker -l info -P eventlet