python—Celery异步分布式

时间：2021-10-29 14:43:25

python—Celery异步分布式

Celery  是一个python开发的异步分布式任务调度模块，是一个消息传输的中间件，可以理解为一个邮箱，每当应用程序调用celery的异步任务时，会向broker传递消息，然后celery的worker从中取消息

Celery  用于存储消息以及celery执行的一些消息和结果

对于brokers，官方推荐是rabbitmq和redis

对于backend，也就是指数据库，为了简单一般使用redis

python—Celery异步分布式

安装启动celery:

pip install celery

windows下，这里还得安装依赖包（协程）

pip install eventlet

下面举个 注册发验证码的 异步任务：

建立单py文件，名称为 tasks.py(必须)

 from celery import Celery

 broker_url = 'redis://127.0.0.1:6379/14'          #任务存放指定库

 result_backend = 'redis://127.0.0.1:6379/15'          #任务执行结束存放指定库

 app = Celery('tasks',broker=broker_url,backend=result_backend)

 from yunpian_python_sdk.model import constant as YC

 from yunpian_python_sdk.ypclient import YunpianClient

 YUNPIAN_KEY = '5f10ebc31xxxxxxxxxxxxxxxxdf3906994833'

 @app.task(name='send_sms_code')

 def send_sms_code(mobile,sms_code):

     '''

     异步发送手机验证码

     '''

     clnt = YunpianClient(YUNPIAN_KEY)

     param = {YC.MOBILE: mobile, YC.TEXT: '【云片网】您的验证码是{}'.format(sms_code)}

     r = clnt.sms().single_send(param)

     print('======返回码{}======API结果{}'.format(r.code(), r.data()))

view.py中调用异步任务：

 from meiduo_mall.utils.tasks import send_sms_code        #导包

 sms_code = '{:0>6d}'.format(random.randint(0,999999))    #生成验证码

 send_sms_code.delay(mobile,sms_code)                     #调用 异步任务执行

前后端任务先运行，然后执行：

celery -A tasks worker -l info -P eventlet

执行 结果：

python—Celery异步分布式

安装启动celery

相关文章