[發明專利]一種批量作業監控方法及裝置、設備及介質

在審

• 申請號: 202210127498.2
• 申請日: 2022-02-11
• 公開（公告）號: CN114500318A
• 公開（公告）日: 2022-05-13
• 發明（設計）人: 曹琎;王亞軍;陳萬紅;邱楓
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: H04L43/08
• 分類號: H04L43/08;H04L43/10;H04L43/16;H04L43/50;H04L41/0631
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 張博

1.一種批量作業監控方法，包括：

接收來自批量作業鏈路中的上游節點的作業報文；

利用來自所述上游節點的作業報文，更新所述批量作業鏈路中當前節點的作業報文，其中，所述當前節點在所述批量作業鏈路中位于所述上游節點的下游；

根據更新后的所述當前節點的作業報文，獲取所述當前節點的作業時長；

在所述當前節點的作業時長滿足預設時間閾值條件的情況下，發出預警信息。

2.根據權利要求1所述的方法，其中，所述作業報文包括批量作業工程名稱、作業節點名稱、作業文件大小、累計作業時長和報錯節點名稱；

其中，所述作業文件大小表示作業節點待處理的文件大小；

其中，所述累計作業時長表示所述批量作業鏈路累計的作業時間；

其中，所述報錯節點名稱用于記錄所述批量作業鏈路中發生作業中斷的節點名稱。

3.根據權利要求2所述的方法，其中，所述利用來自所述上游節點的作業報文，更新所述批量作業鏈路中當前節點的作業報文包括以下至少之一：更新所述當前節點的作業文件大小、更新所述當前節點的累計作業時長以及更新所述當前節點的報錯節點名稱。

4.根據權利要求3所述的方法，其中，所述更新所述當前節點的作業文件大小包括：

通過所述當前節點獲取所述批量作業鏈路中各個上游節點的作業文件大小并進行累加，獲得作業文件大小累加值；

通過所述當前節點的歷史日志文件獲取轉發作業文件大小，其中，所述歷史日志文件用于記錄所述當前節點的歷史作業信息，所述歷史日志文件包括歷史作業文件總數、歷史作業處理時長以及發送到下游節點的轉發作業文件大小；

利用局部加權線性回歸算法處理所述作業文件大小累加值和所述轉發作業文件大小，更新所述當前節點的作業文件大小。

5.根據權利要求3所述的方法，其中，所述更新所述當前節點的累計作業時長包括：

通過所述當前節點的歷史日志文件獲取歷史作業處理時長；

通過局部加權線性回歸算法處理所述歷史作業處理時長和所述當前節點的作業文件大小，確定所述當前作業節點的處理時長；

通過所述當前節點獲取所述批量作業鏈路中各個上游節點的累計作業時長并獲得上游節點累計作業時長的最大值；

通過所述當前作業節點的處理時長和所述上游節點累計作業時長的最大值進行運算，更新所述當前節點的累計作業時長。

6.根據權利要求3所述的方法，其中，所述更新所述當前節點的報錯節點名稱包括：

利用所述當前節點實時檢測所述批量作業鏈路中的所述上游節點的作業狀態；

在所述上游節點發生作業中斷的情況下，將所述當前節點的報錯節點名稱更新為發生作業中斷的上游節點的名稱；

通過所述當前節點利用作業報文將報錯節點名稱在批量作業鏈路中向下游節點傳播；

在所述批量作業鏈路中發生作業中斷的節點恢復的情況下，將所述當前作業節點的作業報文中的報錯節點名稱重置為空。

7.根據權利要求2所述的方法，其中，所述在所述當前節點的作業時長滿足預設時間閾值條件的情況下，發出預警信息：

在所述批量作業鏈路中上游節點的累計作業時長的最大值超過所述當前節點的預設開始作業時間閾值的情況下，通過所述當前節點發出第一預警信息；

在所述當前節點的作業處理時長超過所述當前節點預設的作業處理時間閾值的情況下，通過所述當前節點發出第二預警信息。

8.根據權利要求1所述的方法，還包括：

將所述更新后的當前節點的作業報文發送到所述批量作業鏈路中的下游節點。