Celery批量異步調用任務一直等待結果問題
更新時間：2023年11月24日 09:36:41 作者：lee_star1
這篇文章主要介紹了Celery批量異步調用任務一直等待結果問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
Celery批量異步調用任務一直等待結果
采用celery中group方式進行批量異步調用，且需要等待返回結果時（未設置超時時間）
兩種情況會導致任務一直等待結果：
1. 如果異步方法對異常未進行處理
直接拋出，則會導致group的job一直等待結果，如下代碼：
@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:
raise2. celery出現任務task丟失情況
實際執(zhí)行任務與期待任務數量不符合，則會一直等待結果。因為可能部分開發(fā)者對查看Broker和celery執(zhí)行的情況命令不熟悉，這里推薦安裝Flower監(jiān)控celery，文檔參考Flower文檔。
在執(zhí)行中觀察celery是否掉線，
如下圖：
如果出現掉線，則查看celery日志或者系統日志（/var/log/message）查看是存在進程被kill情況，
如下圖：
總結
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
這篇文章主要為大家詳細介紹了如何基于PyQt5開發(fā)一個視頻水印批量添加工具,旨在為多個視頻文件添加文本水印,感興趣的小伙伴可以參考一下2025-02-02
這篇文章主要介紹了Python中使用filter過濾列表的一個小技巧分享，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-05-05
Python3中l(wèi)ambda表達式與函數式編程講解
今天小編就為大家分享一篇關于Python3中l(wèi)ambda表達式與函數式編程講解，小編覺得內容挺不錯的，現在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-01-01
pydev debugger: process 10341 is co
這篇文章主要介紹了pydev debugger: process 10341 is connecting無法debu的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-04-04
Python中__new__與__init__方法的區(qū)別詳解
這篇文章主要介紹了Python中__new__與__init__方法的區(qū)別,是Python學習中的基礎知識,需要的朋友可以參考下2015-05-05
pygame多種方式實現屏保操作(自動切換、鼠標切換、鍵盤切換)
這篇文章主要介紹了pygame多種方式實現屏保操作(自動切換、鼠標切換、鍵盤切換),文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
Python接口自動化淺析logging日志原理及模塊操作流程
這篇文章主要為大家介紹了Python接口自動化系列文章淺析logging日志原理及模塊操作流程，文中詳細說明了為什么需要日志？日志是什么？以及日志用途等基本的原理2021-08-08
這篇文章主要介紹了Python列表創(chuàng)建與銷毀及緩存池機制，文章基于python展開對列表創(chuàng)建與銷毀內容的展開，具有一定的參考價值，需要的小伙伴可以參考一下2022-05-05
大家好，本篇文章主要講的是Python學習之基礎語法介紹，感興趣的同學趕快來看一看吧，對你有幫助的話記得收藏一下，方便下次瀏覽2021-12-12
這篇文章主要介紹了PyQt5基本控件使用:單選按鈕、復選框、下拉框,本文中的內容和實例也基本回答了開篇提到的問題。需要的朋友可以參考下2019-08-08