最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Celery批量異步調(diào)用任務(wù)一直等待結(jié)果問題

 更新時間：2023年11月24日 09:36:41   作者：lee_star1  
這篇文章主要介紹了Celery批量異步調(diào)用任務(wù)一直等待結(jié)果問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

Celery批量異步調(diào)用任務(wù)一直等待結(jié)果

采用celery中g(shù)roup方式進(jìn)行批量異步調(diào)用，且需要等待返回結(jié)果時（未設(shè)置超時時間）

兩種情況會導(dǎo)致任務(wù)一直等待結(jié)果：

1. 如果異步方法對異常未進(jìn)行處理

直接拋出，則會導(dǎo)致group的job一直等待結(jié)果，如下代碼：

@shared_task(bind=True)
def test_task_method(self, number, is_ignore_exception):
    try:
        logger.info('enter method')
        # if number % 10 == 0:
        #     raise Exception('throw exception')
        time.sleep(15)
    except Exception:
        logger.info(traceback.format_exc())
        if not is_ignore_exception:
            raise

2. celery出現(xiàn)任務(wù)task丟失情況

實(shí)際執(zhí)行任務(wù)與期待任務(wù)數(shù)量不符合，則會一直等待結(jié)果。因?yàn)榭赡懿糠珠_發(fā)者對查看Broker和celery執(zhí)行的情況命令不熟悉，這里推薦安裝Flower監(jiān)控celery，文檔參考Flower文檔。

在執(zhí)行中觀察celery是否掉線，

如下圖：

如果出現(xiàn)掉線，則查看celery日志或者系統(tǒng)日志（/var/log/message）查看是存在進(jìn)程被kill情況，

如下圖：

總結(jié)

以上為個人經(jīng)驗(yàn)，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關(guān)文章

最新評論

本溪市| 镶黄旗| 淳化县| 石渠县| 六安市| 克什克腾旗| 宁城县| 磐石市| 霸州市| 甘孜县| 通道| 遂宁市| 廉江市| 乌海市| 宁波市| 景泰县| 休宁县| 丹凤县| 弥勒县| 齐齐哈尔市| 绥宁县| 铁岭县| 茌平县| 四会市| 黄梅县| 随州市| 大化| 鲁甸县| 彩票| 昌黎县| 嫩江县| 九江县| 枞阳县| 财经| 绿春县| 樟树市| 天祝| 渝中区| 韶山市| 静乐县| 新和县|