Celery解决耗时问题，发短信不尴尬

1，Celery是什么？

• 消息队列，用于存放任务，专注于实时处理问题。

2，Celery有什么用？

• 主要解决耗时问题。包含的三个主体：borker用于存放任务，worker属于工人、消费者，result用于存放结果。

3，Celery的优点？

• 耦合性低，相当与一个第三方插件，使用方便

4，项目中如何体现？

• 用于异步发送短信、发邮件、图片上传等

使用流程：

1，安装：

pip install celery

2，根据celery官方文档：Celery点击Django-->点击使用celery与django-->里面有具体的使用方法。

3，新建celery_test包（根目录下），创建main.py 入口函数文件

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery


#1，设置环境变量（跟项目中的启动文件环境变量相同）
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "app.settings")


#2，创建celery对象（对象名可随便起）
app = Celery('test')
app.config_from_object('celery_test.config', namespace='CELERY'）


#3,注册应用****不要忘记
app.autodiscover_tasks(['celery_test.test.tasks'])   

4，创建config.py配置文件（建立两个redis库，指明存放任务库和存放结果库）

broker_url='redis://127.0.0.1:6379/14'  #存放任务
result_backend='redis://127.0.0.1:6379/15' #存放结果

5，在celery_test包内创建sms包，专门用于存放发送短息的任务，发送短信的模板（发短信使用的是第三方容联云通讯）

from celery_test.main import app
from app.libs.yuntongxun.sms import CCP

#bind: 会将第一个参数绑定到函数的第一参数，就是说参数self必填
#name: 表示任务的名称
@app.task(bind=True,name="sms_code")
def send_sms_code(self,mobile,sms_code,time):
    # import time
    # time.sleep(10)
    #1,发送短信
    try:
        ccp = CCP()
        result =  ccp.send_template_sms(mobile, [sms_code, time], 1)
    except Exception as e:
        result = -1
    #2,判断结果 （countdown:隔多久发一次，max_retries:最多发几次，exc：过期时间抛出异常）
    if result == -1:
        print("重试中....")
        self.retry(countdown=5,max_retries=3,exc=Exception("发送短信失败啦!!!"))

终端测试发送命令： celery -A celery_test.main worker -l info