Celery是一个简单，灵活，可靠的分布式系统，用于处理大量消息，同时为操作提供维护此类系统所需的工具。它是一个任务队列，专注于实时处理，同时还支持任务调度。
在开发过程中，耗时长，超时的任务经常发生，比如：获取后端某个大文件数据超时、需要后端计算任务超时，等等，此时我们就会很自然的想到异步方式，根据需要完成的任务创建一个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
文章来源网络，作者：运维，如若转载，请注明出处：https://shuyeidc.com/wp/207663.html<
