flask 异步celery使用
发布于2019-08-07 14:03 阅读(1197) 评论(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黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容：(最多支持255个字符)
---无人问津也好，技不如人也罢，你都要试着安静下来，去做自己该做的事，而不是让内心的烦躁、焦虑，坏掉你本来就不多的热情和定力