详解flask异步celery使用

Celery是一个简单，灵活，可靠的分布式系统，用于处理大量消息，同时为操作提供维护此类系统所需的工具。它是一个任务队列，专注于实时处理，同时还支持任务调度。

成都创新互联专注于企业成都全网营销、网站重做改版、安徽网站定制设计、自适应品牌网站建设、成都h5网站建设、商城网站建设、集团公司官网建设、成都外贸网站建设公司、高端网站制作、响应式网页设计等建站业务，价格优惠性价比高，为安徽等各大城市提供网站开发制作服务。

在开发过程中，耗时长，超时的任务经常发生，比如：获取后端某个大文件数据超时、需要后端计算任务超时，等等，此时我们就会很自然的想到异步方式，根据需要完成的任务创建一个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

网页名称：详解flask异步celery使用
文章路径：http://www.shufengxianlan.com/qtweb/news27/542277.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联