python—Celery异步分布式

Posted lvye001

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python—Celery异步分布式相关的知识,希望对你有一定的参考价值。

python—Celery异步分布式

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

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

 

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

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

 

安装启动celery:

pip install celery

windows下,这里还得安装依赖包(协程)

 

pip install eventlet

 

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

 

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

 

 1 from celery import Celery
 2 
 3 broker_url = \'redis://127.0.0.1:6379/14\'          #任务存放指定库
 4 result_backend = \'redis://127.0.0.1:6379/15\'          #任务执行结束存放指定库
 5 app = Celery(\'tasks\',broker=broker_url,backend=result_backend)
 6 
 7 from yunpian_python_sdk.model import constant as YC
 8 from yunpian_python_sdk.ypclient import YunpianClient
 9 
10 YUNPIAN_KEY = \'5f10ebc31xxxxxxxxxxxxxxxxdf3906994833\'
11 
12 @app.task(name=\'send_sms_code\')
13 def send_sms_code(mobile,sms_code):
14     \'\'\'
15     异步发送手机验证码
16     \'\'\'
17     clnt = YunpianClient(YUNPIAN_KEY)
18     param = {YC.MOBILE: mobile, YC.TEXT: \'【云片网】您的验证码是{}\'.format(sms_code)}
19     r = clnt.sms().single_send(param)
20     print(\'======返回码{}======API结果{}\'.format(r.code(), r.data()))

 

view.py中调用异步任务:

1 from meiduo_mall.utils.tasks import send_sms_code        #导包
2 
3 sms_code = \'{:0>6d}\'.format(random.randint(0,999999))    #生成验证码
4 
5 send_sms_code.delay(mobile,sms_code)                     #调用 异步任务执行

前后端任务先运行,然后执行:

celery -A tasks worker -l info -P eventlet

 执行 结果:

 

 

 

 

 

 

安装启动celery

 

以上是关于python—Celery异步分布式的主要内容,如果未能解决你的问题,请参考以下文章

Python开发模块:Celery 分布式异步消息任务队列

理论python使用celery异步处理请求

Python开发模块:Celery 分布式异步消息任务队列

python3+celery+redis实现异步任务

python-celery专注于实现分布式异步任务处理任务调度的插件!

Celery异步的分布式任务调度理解