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