[發明專利]任務監控方法、裝置、電子設備及存儲介質

在審

• 申請號: 202010151372.X
• 申請日: 2020-03-06
• 公開（公告）號: CN111400130A
• 公開（公告）日: 2020-07-10
• 發明（設計）人: 戴文鵬
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F9/54;G06F16/22;G06F16/2455;G06F16/27
• 代理公司: 深圳市沃德知識產權代理事務所(普通合伙) 44347
• 代理人: 高杰;于志光

1.一種任務監控方法，其特征在于，所述方法包括：

當接收到待監控任務時，將所述待監控任務輸入至任務系統；

同步所述任務系統中與所述待監控任務相關的預設種類的信息至項目任務監控平臺；

在所述項目任務監控平臺，基于Spark Streaming框架對所述信息進行實時處理，得到任務數據，顯示并存儲所述任務數據；

當接收到對所述待監控任務的監控指令時，從所述監控指令中獲取所述待監控任務的參數信息；

根據所述參數信息在所述任務數據中進行查詢，得到所述待監控任務的當前運行數據及歷史運行數據；

計算所述當前運行數據與所述歷史運行數據的差異值；

當所述差異值大于配置閾值時，確定所述待監控任務異常。

2.如權利要求1所述的任務監控方法，其特征在于，所述同步所述任務系統中與所述待監控任務相關的預設種類的信息至項目任務監控平臺，包括：

當所述信息為指定任務的運行信息時，利用哈希函數計算所述運行信息的分片號；

基于所述分片號將所述運行信息同步至Kafka消息隊列。

3.如權利要求2所述的任務監控方法，其特征在于，所述利用哈希函數計算所述運行信息的分片號，包括：

通過分片函數的計算結果對預設的哈希桶取模，得到所述分片號，其中，所述分片函數如下：

其中，Hash_Bucket為所述預設的哈希桶，slice_id是指所述運行信息的分片號，是指按照名稱分布時所述運行信息的量化函數，day_time(time)是指按照時間分布時所述運行信息的量化函數，b1是指按照名稱分布時相鄰信息間的分散程度，b2是指按照時間分布時相鄰信息間的分散程度，w1是指按照名稱分布時的未標準化權重，w2是指按照時間分布時的未標準化權重。

4.如權利要求3所述的任務監控方法，其特征在于，所述方法還包括：

設置w2為0，以按照名稱將所述運行信息同步至所述Kafka消息隊列；或者

設置w1為0，以按照時間將所述運行信息同步至所述Kafka消息隊列。

5.如權利要求1所述的任務監控方法，其特征在于，所述同步所述任務系統中與所述待監控任務相關的預設種類的信息至項目任務監控平臺，還包括：

采用Elasticsearch從所述任務系統中查詢Java微服務的日志信息；

基于Logstash對所述日志信息進行分析及過濾；

采用Kibana對分析及過濾后的日志信息進行可視化處理；

基于Logstash同步可視化處理后的日志信息至所述項目任務監控平臺。

6.如權利要求1所述的任務監控方法，其特征在于，所述根據所述參數信息在所述任務數據中進行查詢，得到所述待監控任務的當前運行數據及歷史運行數據，包括：

當所述任務數據存儲在數據庫中時，基于預設詞典構建ES搜索引擎；

基于所述ES搜索引擎，根據所述參數信息在所述數據庫中進行查詢，得到所述待監控任務的當前運行數據及歷史運行數據。

7.如權利要求6所述的任務監控方法，其特征在于，所述基于所述ES搜索引擎，根據所述參數信息在所述數據庫中進行查詢，得到所述待監控任務的當前運行數據及歷史運行數據，包括：

在所述ES搜索引擎下的多個配置字典中遍歷所述參數信息，得到索引信息；

根據所述索引信息在所述數據庫中進行查詢，得到所述待監控任務的當前運行數據及歷史運行數據。