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

此时我们就会很自然的想到异步方式,根据需要完成的任务创建一个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

 

版权声明:本文为zj-Rules原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/zj-Rules/p/11314061.html