标签：生成 tps expires 没有 其他 template 安装环境 ant obj
Celery是一个用Python开发的异步的分布式任务调度模块。
Celery本身不包含消息服务，使用第三方消息服务，也就是Broker，来传递任务，目前支持的有Rebbimq，Redis，数据库以及其他的一些比如Amazon SQS,Monogdb和IronMQ 。
Celery支持同步和异步执行两种模式。同步模式为任务调用方等待任务执行完成，这种方式等同于RPC(Remote Procedure Call)， 异步方式为任务在后台执行，调用方调用后就去做其他工作，之后再根据需要来查看任务结果。Celery自己没有实现消息队列，而是直接已存在的消息队列作为Broker角色。官方推荐的Broker为 RabbitMQ ，除此之外，Redis、Beanstalkd、MongoDB等也都支持，具体可参考 官方文档 。
Celery整体架构可以理解为下图:
关于Redis和Rebbimq 消息队列的比较：https://www.cnblogs.com/lzc978/articles/10291597.html
pip install celery
celery -A 应用的包路路径 worker -l info
# celery配置文件 # 指定任务队列列的位置 使用redis做为broker任务队列 broker_url = "redis://192.168.103.210/7"
# celery启动文件 from celery import Celery # 创建celery实例例 celery_app = Celery(‘file‘) # 加载celery配置 celery_app.config_from_object(‘celery_tasks.config‘) # 自动注册celery任务 celery_app.autodiscover_tasks([‘celery_tasks.sms‘])
# 发送短信的异步任务 from .yuntongxun.sms import CCP from . import constants from celery_tasks.main import celery_app # 装饰器?将send_sms_code装饰为异步任务,并设置别名 @celery_app.task(name=‘send_sms_code‘) def send_sms_code(mobile, sms_code): """ 发送短信异步任务 :param mobile: 手机号 :param sms_code: 短信验证码 :return: None """ CCP().send_template_sms(mobile, [sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60], constants.SEND_SMS_TEMPLATE_ID)
celery -A celery_tasks.main worker -l info
# 生成和发送短信验证码 sms_code = ‘%06d‘ % random.randint(0,999999) # CCP().send_template_sms(mobile,[sms_code, constants.SMS_CODE_REDIS_EXPIRES // 60], 1) # celery异步发送短信 send_sms_code.delay(mobile,sms_code)
至此，一个简单的异步分布式Celery(异步任务)服务器搭建完成
标签：生成 tps expires 没有 其他 template 安装环境 ant obj
原文地址：https://www.cnblogs.com/lzc978/p/10296273.html
