[發明專利]作業調度系統的作業監控方法、裝置、介質及電子設備

在審

• 申請號: 202111266458.8
• 申請日: 2021-10-28
• 公開（公告）號: CN114020566A
• 公開（公告）日: 2022-02-08
• 發明（設計）人: 洪鈞煌;王呈炎;陳良龍;蘇建清;林淇;翁志山
• 申請（專利權）人: 建信金融科技有限責任公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F9/48
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 趙迎迎

1.一種作業調度系統的作業監控方法，其特征在于，所述方法包括：

若檢測到作業執行單元被創建，則獲取所述執行單元信息；

若檢測到作業流水線初始化，則獲取作業流水線信息；

作業執行過程中，通過預先埋入在作業調度系統中的作業關鍵路徑的埋點，采用預先設置的監控數據獲取規則獲取作業的狀態信息；

將所述執行單元信息、作業流水線信息和狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲。

2.根據權利要求1所述的方法，其特征在于，作業執行過程中，通過預先埋入在作業調度系統中的作業關鍵路徑的埋點，采用預先設置的監控數據獲取規則獲取作業的狀態信息，包括：

作業執行過程中，通過預先埋入在作業調度系統中的作業關鍵路徑的埋點獲取作業的當前的狀態信息；

識別所述當前的狀態信息對應的事件是否存在前置事件；

若存在，采集所述前置事件的狀態信息，并與所述當前的狀態信息一并獲??；

相應的，將所述執行單元信息、作業流水線信息和狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲，包括：

將所述執行單元信息、作業流水線信息、當前的狀態信息和前置事件的狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲。

3.根據權利要求2所述的方法，其特征在于，采用預先設置的監控數據獲取規則獲取作業的狀態信息，包括：

采用當前時間戳信息作為作業的狀態信息。

4.根據權利要求1所述的方法，其特征在于，所述作業調度系統中的作業關鍵路徑的埋點的埋入方式，包括：

在所述作業執行路徑中確定作業關鍵節點，以構成關鍵路徑；

針對每個作業關鍵節點，注冊回調函數；其中，所述回調函數用于在執行到所述作業關鍵節點時被觸發，以形成關鍵路徑的埋點。

5.根據權利要求1所述的方法，其特征在于，在獲取作業流水線信息之后，所述方法還包括：

作業執行過程中，根據預先配置的自定義監控指標，獲取作業的自定義信息；

相應的，將所述執行單元信息、作業流水線信息和狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲，包括：

將所述執行單元信息、自定義信息、作業流水線信息和狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲。

6.根據權利要求5所述的方法，其特征在于，所述自定義監控指標的配置過程，包括：

響應于配置界面的觸發操作，顯示配置界面；

響應于自定義監控指標的選擇請求，將候選指標中確定被選擇的作為自定義監控指標；其中，所述自定義監控指標為通過作業關鍵路徑的埋點和/或通過自定義埋點獲取的。

7.根據權利要求6所述的方法，其特征在于，所述自定義監控指標包括運行作業耗時指標、資源消耗指標以及錯誤上報指標中的至少一種；

所述自定義監控指標的選擇請求，包括自定義監控指標的選擇結果，或者，包括自定義監控指標的選擇規則。

8.根據權利要求1所述的方法，其特征在于，在將聚合結果推送到監控數據庫存儲之后，所述方法還包括：

響應于作業查詢請求，根據作業所屬的作業流水線信息，確定所述作業流水線上各狀態信息對應的事件。

9.一種作業調度系統的作業監控裝置，其特征在于，所述裝置包括：

執行單元信息獲取模塊，用于若檢測到作業執行單元被創建，則獲取所述執行單元信息；

作業流水線信息獲取模塊，用于若檢測到作業流水線初始化，則獲取作業流水線信息；

狀態信息獲取模塊，用于作業執行過程中，通過預先埋入在作業調度系統中的作業關鍵路徑的埋點，采用預先設置的監控數據獲取規則獲取作業的狀態信息；

聚合存儲模塊，用于將所述執行單元信息、作業流水線信息和狀態信息進行聚合，并將聚合結果推送到監控數據庫存儲。