建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
詳解flask異步celery使用
Celery是一個簡單，靈活，可靠的分布式系統(tǒng)，用于處理大量消息，同時為操作提供維護(hù)此類系統(tǒng)所需的工具。它是一個任務(wù)隊列，專注于實時處理，同時還支持任務(wù)調(diào)度。
成都創(chuàng)新互聯(lián)專注于企業(yè)成都全網(wǎng)營銷、網(wǎng)站重做改版、安徽網(wǎng)站定制設(shè)計、自適應(yīng)品牌網(wǎng)站建設(shè)、成都h5網(wǎng)站建設(shè)、商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計等建站業(yè)務(wù)，價格優(yōu)惠性價比高，為安徽等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。
在開發(fā)過程中，耗時長，超時的任務(wù)經(jīng)常發(fā)生，比如：獲取后端某個大文件數(shù)據(jù)超時、需要后端計算任務(wù)超時，等等，此時我們就會很自然的想到異步方式，根據(jù)需要完成的任務(wù)創(chuàng)建一個task_id, 由前端來監(jiān)聽該任務(wù)是否完成。
初始化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
在方法調(diào)用時，需要使用fun.delay(args)
add.delay(1,2)
celery啟動
celery -A apps.celery worker -l info --concurrency=3
坑：在使用celery異步進(jìn)行數(shù)據(jù)庫進(jìn)行交互時，務(wù)必手動斷開連接，否則容易造成，lost connection error
分享題目：詳解flask異步celery使用
文章地址：http://m.5511xx.com/article/djoisgg.html
