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的启动文件

1from celery import Celery
2
3# 为celery使用django配置文件进行设置
4import os
5if not os.getenv('DJANGO_SETTINGS_MODULE'):
6    os.environ['DJANGO_SETTINGS_MODULE'] = 'xiangmu_api.settings'
7
8# 创建celery应用
9app = Celery('xiangmu')
10
11# 导入celery配置
12app.config_from_object('celery_tasks.config')
13
14# 自动注册celery任务
15app.autodiscover_tasks(['celery_tasks.sms'])

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

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

1import logging
2
3from celery_tasks.main import app
4from utils.ytx_sdk.sendSMS import CCP
5
6logger = logging.getLogger("django")
7
8
9@app.task(name='send_sms_code')
10def send_sms_code(mobile, code, expires, template_id):
11    """
12    发送短信验证码
13    :param mobile: 手机号
14    :param code: 验证码
15    :param expires: 有效期
16    :return: None
17    """
18
19    try:
20        # result = CCP.send_template_sms(mobile, [code, expires], template_id)
21        result = 0
22        print(code)
23    except Exception as e:
24        logger.error("发送验证码短信[异常][ mobile: %s, message: %s ]" % (mobile, e))
25    else:
26        if result == 0:
27            logger.info("发送验证码短信[正常][ mobile: %s ]" % mobile)
28        else:
29            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