[發明專利]分布式告警系統、方法和裝置

在審

• 申請號: 202110587596.X
• 申請日: 2021-05-27
• 公開（公告）號: CN113282460A
• 公開（公告）日: 2021-08-20
• 發明（設計）人: 馬剛;韓昕哲;趙錫成
• 申請（專利權）人: 中國聯合網絡通信集團有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 余娜;黃健

本申請提供一種分布式告警系統、方法和裝置，應用于數據處理領域。系統包括：應用端服務接口參數采集組件、告警信息傳輸組件和日志分析組件。通過系統中的應用端服務接口參數采集組件確定告警信息，告警信息傳輸組件匯集告警信息，并向開源流處理平臺Kafka異步發送告警信息，日志分析組件將從Kafka獲取的告警信息進行分析，并根據分析結果進行告警，這樣，在分布式應用里，調用接口完成業務時，可以通過該系統所進行的告警，實時發現接口的質量問題。

技術領域

本申請涉及數據處理領域，尤其涉及一種分布式告警系統、方法和裝置。

背景技術

隨著互聯網的快速發展和演進，不斷變化的商業環境所帶來的業務需求，使得應用端需要處理復雜而耗時的業務，由于分布式應用可以在網絡中的多個系統上運行，且可以通過使用多個系統的計算能力，因此，可以使用分布式快速有效地完成業務。

通常的，在分布式應用里，可以調用接口完成業務。例如，分布式應用包括應用端應用程序和服務端應用程序，服務端應用程序可以通過調用接口完成應用端應用程序的業務，從而使得應用端可以得到業務的處理結果。

但是，調用接口完成業務時，由于接口的提供方可能是第三方，可能無法發現接口的質量問題。

發明內容

第一方面，本申請實施例提供一種分布式告警系統，包括：應用端服務接口參數采集組件、告警信息傳輸組件和日志分析組件；其中，所述應用端服務接口參數采集組件和所述告警信息傳輸組件設置在至少一個終端設備中，所述日志分析組件設置在服務器中，所述終端設備與所述服務器有線或無線通信；

其中，所述應用端服務接口參數采集組件，用于采集所述應用端服務接口參數采集組件所在的終端設備的外部接口調用相關參數，并根據所述外部接口調用相關參數確定告警信息；

所述告警信息傳輸組件，用于匯集所述告警信息，并向所述開源流處理平臺Kafka異步發送所述告警信息；

所述日志分析組件，用于從所述Kafka獲取所述告警信息，分析所述告警信息，并根據分析得到的結果進行告警。

一種可能的實現方式中，所述外部接口調用相關參數包括：調用所述外部接口時的響應時間和/或異常信息；

所述應用端服務接口參數采集組件，具體用于在確定所述外部接口正常調用時，判斷所述響應時間是否超過閾值，若所述響應時間超過閾值，產生所述告警信息。

一種可能的實現方式中，所述應用端服務接口參數采集組件，具體還用于在確定所述外部接口異常調用時，捕獲所述異常調用中產生的異常信息，并將所述異常信息整合在所述告警信息中。

一種可能的實現方式中，所述應用端服務接口參數采集組件，還用于將所述告警信息發送到共享內存隊列；其中，所述共享內存隊列由所述告警信息傳輸組件提供，所述共享內存隊列用于將所述告警信息發送到所述告警信息傳輸組件。

一種可能的實現方式中，所述日志分析組件，還用于對所述告警信息進行持久化。

一種可能的實現方式中，所述日志分析組件，具體用于將預設時間內產生的同一個外部接口的同一類告警信息進行合并，得到一條分析結果。

一種可能的實現方式中，所述日志分析組件，具體還用于將所述一條分析結果通過短信發送至預設號碼。

第二方面，本申請實施例提供一種分布式告警方法，該方法應用于第一方面描述的分布式告警系統，所述方法包括：

采集應用端服務接口參數采集組件所在的終端設備的外部接口調用相關參數，并根據所述外部接口調用相關參數確定告警信息；

匯集所述告警信息，并向所述開源流處理平臺Kafka異步發送所述告警信息；