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