zoukankan      html  css  js  c++  java
  • 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

     执行 结果:

     

  • 相关阅读:
    磁盘挂载基本概念
    判断cache Line的作用
    map的用法
    java中关键字volatile的作用
    Java获取用户输入
    小白说编译原理lex和yacc环境配置-多图
    C++中对sprintf()函数的说明(转)
    解决VS编译DevExpress后Debug默认产生几个多余的语言包"de" "en" "es" "ja" "ru"的问题
    SqlServer发现不是默认端口1433该如何进行连接
    量化交易之接口篇 — 恒生UFX交易接口基本介绍说明
  • 原文地址:https://www.cnblogs.com/gaosai/p/10106995.html
Copyright © 2011-2022 走看看