ITPub博客

首页 > 应用开发 > Python > flask异步数据交换celery的使用

flask异步数据交换celery的使用

Python 作者:安全剑客 时间:2019-08-20 22:00:00 0 删除 编辑
在开发过程中,耗时长,超时的任务经常发生,比如:获取后端某个大文件数据超时、需要后端计算任务超时,等等,此时我们就会很自然的想到异步方式,根据需要完成的任务创建一个task_id, 由前端来监听该任务是否完成。
初始化celery
celery = Celery('celery_demo', broker=app.config.get('CELERY_BROKER_URL'),backend=app.config.get('CELERY_BACKEND_URL'))
在需要异步执行的方法上使用@celery.task装饰器
@celery.task
 def add(a,b):
  return a+b
在方法调用时,需要使用fun.delay(args)
add.delay(1,2)
celery启动
celery -A apps.celery worker -l info --concurrency=3

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


来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/31559985/viewspace-2654354/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2018-11-01

  • 博文量
    584
  • 访问量
    372736