[發明專利]基于圖數據庫的作業鏈任務延遲預警方法、裝置和設備

在審

• 申請號: 202210030456.7
• 申請日: 2022-01-12
• 公開（公告）號: CN114356720A
• 公開（公告）日: 2022-04-15
• 發明（設計）人: 張丹豐
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 鈄颯颯;臧建明

1.一種基于圖數據庫的作業鏈任務延遲預警方法，其特征在于，所述方法包括：

在作業鏈運行過程中，監測所述作業鏈中各節點的任務執行狀態；

當監測到作業節點的任務執行狀態表征任務執行失敗時，從所述作業鏈的拓撲結構信息中搜索任務執行失敗的作業節點的關聯節點；其中，所述作業鏈的拓撲結構信息基于圖數據庫存儲，所述作業鏈的拓撲結構信息中包括所述作業鏈中各節點之間的關系信息；

生成延遲預警信息，所述延遲預警信息用于指示所述關聯節點存在任務延遲風險。

2.根據權利要求1所述的方法，其特征在于，所述作業鏈的拓撲結構信息中還包括所述作業鏈中各節點的延時閾值記錄；所述方法還包括：

從所述作業鏈的拓撲結構信息中獲取所述作業節點的當前延時閾值，所述作業節點的當前延時閾值表示所述作業節點最新記錄的延時閾值；

當所述作業節點的任務延時超過所述作業節點的當前延時閾值時，判定所述作業節點的任務執行狀態表征任務執行失敗。

3.根據權利要求2所述的方法，其特征在于，所述作業鏈的拓撲結構信息中還包括所述作業鏈中各節點的任務執行數據記錄；

當監測到作業節點的任務執行狀態表征任務執行失敗時，還包括：

對所述作業鏈的拓撲結構信息中所述作業節點的任務執行數據記錄進行更新；

根據更新后的所述作業節點的任務執行數據記錄，對所述作業節點的當前延時閾值進行調整，記錄所述作業節點調整后的延時閾值。

4.根據權利要求3所述的方法，其特征在于，更新后的所述作業節點的任務執行數據記錄中包括所述作業節點的連續失敗執行次數；

根據更新后的所述作業節點的任務執行數據記錄，對所述作業節點的當前延時閾值進行調整，記錄所述作業節點調整后的延時閾值，包括：

根據所述作業節點的連續失敗執行次數，對所述作業節點的當前延時閾值進行上調，獲得所述作業節點上調后的延時閾值；

記錄所述作業節點上調后的延時閾值。

5.根據權利要求4所述的方法，其特征在于，根據所述作業節點的連續失敗執行次數，對所述作業節點的當前延時閾值進行上調，獲得所述作業節點上調后的延時閾值，包括：

若根據所述作業節點的連續失敗執行次數，對所述作業節點的當前延時閾值進行上調后獲得的延時閾值超過預設的閾值上限，則將所述閾值上限確定為所述作業節點上調后的延時閾值。

6.根據權利要求3所述的方法，其特征在于，所述方法還包括：

從所述作業鏈的拓撲結構信息中獲取各所述關聯節點的當前延時閾值和任務執行數據記錄，所述關聯節點的當前延時閾值表示所述關聯節點最新記錄的延時閾值；

根據各所述關聯節點的任務執行數據記錄，對各所述關聯節點的當前延時閾值進行調整，記錄各所述關聯節點調整后的延時閾值。

7.根據權利要求6所述的方法，其特征在于，根據各所述關聯節點的任務執行數據記錄，對各所述關聯節點的當前延時閾值進行調整，記錄各所述關聯節點調整后的延時閾值，包括：

對于任一所述關聯節點，若所述關聯節點的任務執行數據記錄中的最新記錄為成功執行數據，則獲取所述關聯節點的連續成功執行次數；

根據所述關聯節點的連續成功執行次數，對所述關聯節點的當前延時閾值進行衰減，獲得所述關聯節點衰減后的延時閾值；

記錄所述關聯節點衰減后的延時閾值。

8.根據權利要求6所述的方法，其特征在于，根據各所述關聯節點的任務執行數據記錄，對各所述關聯節點的當前延時閾值進行調整，記錄各所述關聯節點調整后的延時閾值，包括：

對于任一所述關聯節點，若所述關聯節點的任務執行數據記錄中的最新記錄為失敗執行數據，則獲取所述關聯節點的連續失敗執行次數；

根據各所述關聯節點的連續失敗執行次數，對所述關聯節點的當前延時閾值進行上調，獲得所述關聯節點上調后的延時閾值；

記錄所述關聯節點上調后的延時閾值。