[發明專利]數據監控告警方法、裝置、計算機設備及存儲介質

有效

• 申請號: 202011620064.3
• 申請日: 2020-12-30
• 公開（公告）號: CN112732536B
• 公開（公告）日: 2023-01-13
• 發明（設計）人: 楊楠;張宇駿;張強;黃新華
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06F11/32
• 分類號: G06F11/32;G06F11/30;G06F18/241
• 代理公司: 深圳眾鼎專利商標代理事務所(普通合伙) 44325
• 代理人: 譚果林

本發明公開一種數據監控告警方法、裝置、計算機設備及存儲介質。該方法包括：采集源數據，將所述源數據傳輸到Kafka組件進行解耦；對所述源數據進行場景分類，確定所述Kafka組件解耦后的源數據對應的場景類型；采用所述場景類型對應的格式轉譯邏輯，對所述場景類型對應的源數據進行格式轉譯，獲取標準指標數據；獲取與所述場景類型相對應的監控指標數據；對所述場景類型對應的所述標準指標數據和所述監控指標數據進行異常監控，獲取告警監控結果；若所述告警監控結果為需要告警，則形成目標告警消息，采用與所述場景類型相對應的告警通知邏輯，將所述目標告警消息發送給業務終端。該方法可以有效提高數據監控告警的處理效率，保障異常情況的及時處理。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種數據監控告警方法、裝置、計算機設備及存儲介質。

背景技術

監控告警平臺(如Detector)是用于實現對數據處理的整個流程進行監控告警的平臺，例如，從數據生成、計算、對比和發送等各個環節進行監控告警。現有監控告警平臺在數據處理的各個環節高度耦合、數據結構多樣性、處理流程僅限于單一渠道，無法適應數據來源及渠道多樣性的要求，使得現有監控告警平臺在數據監控告警過程中，處理效率較低，導致告警消息發送不及時。

發明內容

本發明實施例提供一種數據監控告警方法、裝置、計算機設備及存儲介質，以解決數據監控告警問題。

一種數據監控告警方法，包括：

采集源數據，將所述源數據傳輸到Kafka組件進行解耦；

對所述Kafka組件解耦后的源數據進行場景分類，確定所述源數據對應的場景類型；

采用所述場景類型對應的格式轉譯邏輯，對所述場景類型對應的源數據進行格式轉譯，獲取標準指標數據；

獲取與所述場景類型相對應的監控指標數據；

對所述場景類型對應的所述標準指標數據和所述監控指標數據進行異常監控，獲取告警監控結果；

若所述告警監控結果為需要告警，則形成目標告警消息，采用與所述場景類型相對應的告警通知邏輯，將所述目標告警消息發送給業務終端。

一種數據監控告警裝置，包括：

源數據采集模塊，用于采集源數據，將所述源數據傳輸到Kafka組件進行解耦；

場景類型確定模塊，用于對所述Kafka組件解耦后的源數據進行場景分類，確定所述源數據對應的場景類型；

標準指標數據獲取模塊，用于采用所述場景類型對應的格式轉譯邏輯，對所述場景類型對應的源數據進行格式轉譯，獲取標準指標數據；

監控指標數據獲取模塊，用于獲取與所述場景類型相對應的監控指標數據；

告警監控結果獲取模塊，用于對所述場景類型對應的所述標準指標數據和所述監控指標數據進行異常監控，獲取告警監控結果；

目標告警消息發送模塊，用于若所述告警監控結果為需要告警，則形成目標告警消息，采用與所述場景類型相對應的告警通知邏輯，將所述目標告警消息發送給業務終端。

一種計算機設備，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述數據監控告警方法。

一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現上述數據監控告警方法。