建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯網營銷解決方案
詳解flask異步celery使用
Celery是一個簡單，靈活，可靠的分布式系統(tǒng)，用于處理大量消息，同時為操作提供維護此類系統(tǒng)所需的工具。它是一個任務隊列，專注于實時處理，同時還支持任務調度。
成都創(chuàng)新互聯專注于企業(yè)成都全網營銷、網站重做改版、安徽網站定制設計、自適應品牌網站建設、成都h5網站建設、商城網站建設、集團公司官網建設、成都外貿網站建設公司、高端網站制作、響應式網頁設計等建站業(yè)務，價格優(yōu)惠性價比高，為安徽等各大城市提供網站開發(fā)制作服務。
在開發(fā)過程中，耗時長，超時的任務經常發(fā)生，比如：獲取后端某個大文件數據超時、需要后端計算任務超時，等等，此時我們就會很自然的想到異步方式，根據需要完成的任務創(chuàng)建一個task_id, 由前端來監(jiān)聽該任務是否完成。
初始化celery
celery = Celery('celery_demo', broker=app.config.get('CELERY_BROKER_URL'),backend=app.config.get('CELERY_BACKEND_URL'))
在需要異步執(zhí)行的方法上使用@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.dlmjj.cn/article/djoisgg.html
