本站消息

站长简介/公众号


站长简介:高级软件工程师,曾在阿里云,每日优鲜从事全栈开发工作,利用周末时间开发出本站,欢迎关注我的微信公众号:程序员总部,程序员的家,探索程序员的人生之路!分享IT最新技术,关注行业最新动向,让你永不落伍。了解同行们的工资,生活工作中的酸甜苦辣,谋求程序员的最终出路!

  价值13000svip视频教程,python大神匠心打造,零基础python开发工程师视频教程全套,基础+进阶+项目实战,包含课件和源码

  出租广告位,需要合作请联系站长

+关注
已关注

分类  

暂无分类

标签  

暂无标签

日期归档  

2020-12(21)

2021-01(51)

flask 异步celery使用

发布于2019-08-07 14:03     阅读(176)     评论(0)     点赞(5)     收藏(2)



在开发过程中,耗时长,超时的任务经常发生,比如:获取后端某个大文件数据超时、需要后端计算任务超时,等等,

此时我们就会很自然的想到异步方式,根据需要完成的任务创建一个task_id, 由前端来监听该任务是否完成。

本文主要分享:flask中实现异步功能--celery,【后续django异步待更新】

flask 中使用celery,只需要简单四步:

1.初始化celery【配置broker 和 backend】

  celery = Celery('celery_demo', broker=app.config.get('CELERY_BROKER_URL'),backend=app.config.get('CELERY_BACKEND_URL'))

2.在需要异步执行的方法上使用@celery.task装饰器

  @celery.task

  def add(a,b):

    return a+b

3.在方法调用时,需要使用fun.delay(args)

  add.delay(1,2)

4.celery 启动

  celery -A apps.celery worker -l info --concurrency=3

坑:在使用celery异步进行数据库进行交互时,务必手动断开连接,否则容易造成,lost connection error

 







所属网站分类: 技术文章 > 博客

作者:343489399

链接:https://www.pythonheidong.com/blog/article/11255/06d8183fca121c888326/

来源:python黑洞网

任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任

5 0
收藏该文
已收藏

评论内容:(最多支持255个字符)