[發明專利]一種數據通信業務質量監控的方法及大數據系統

有效

• 申請號: 201710373959.3
• 申請日: 2017-05-24
• 公開（公告）號: CN108964957B
• 公開（公告）日: 2022-08-02
• 發明（設計）人: 周悅來
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: H04L41/069
• 分類號: H04L41/069;H04L41/0631;H04L41/0677;G06F16/14;G06F16/182;G06F16/2458
• 代理公司: 北京天昊聯合知識產權代理有限公司 11112
• 代理人: 姜春咸;馮建基

1.一種數據通信業務質量監控的方法，包括：

大數據系統通過對各個網元的話單日志服務器發送的日志數據進行日志處理，得到各網元的日志處理結果和日志統計結果，所述日志處理結果和日志統計結果存儲在所述大數據系統的Elasticsearch模塊；

大數據系統根據所述Elasticsearch模塊內存儲的各網元日志處理結果和日志統計結果對該網元日志的關鍵性指標數據進行業務質量監控，判斷所述網元日志的關鍵性指標數據是否存在風險；

若判斷所述網元日志關鍵性指標數據存在風險，則大數據系統向運維人員發出數據通信業務質量的預警提示。

2.根據權利要求1所述的方法，其中，部署在每個網元的話單日志服務器中kafkaproducers模塊收集所在網元的日志數據，并將其進行編碼后發送到所述大數據系統的brokers模塊。

3.根據權利要求2所述的方法，其中，所述brokers模塊收到來自各個網元編碼后的日志數據后，保存所述各網元編碼后的日志數據，并啟動所述大數據系統的spark streaming任務調用kafka consumer模塊。

4.根據權利要求3所述的方法，其中，所述kafka consumer模塊被調用后，提取所述brokers模塊保存的各網元編碼后的日志數據，并對所述日志數據解碼后進行日志處理，得到各網元的日志處理結果和日志統計結果。

5.根據權利要求4所述的方法，其中，所述kafka consumer模塊將所得到的各網元的日志處理結果和日志統計結果發送到所述大數據系統的Elasticsearch模塊，同時將各網元的日志統計結果發送到所述大數據系統的分布式文件系統HDFS模塊，以便需要進行各網元的離線日志統計時，讀取并統計所述HDFS模塊中各網元的日志統計結果，得到各網元的離線日志統計結果，并將其發送到所述Elasticsearch模塊。

6.根據權利要求5所述的方法，其中，所述大數據系統的Websphere應用服務器WAS模塊通過讀取所述Elasticsearch模塊中各網元的日志處理結果和日志統計結果，對該網元日志的關鍵性指標數據進行業務質量監控，判斷所述網元日志的關鍵性指標數據是否存在風險，并在判斷所述網元日志關鍵性指標數據存在風險時向運維人員發出數據通信業務質量的預警提示。

7.根據權利要求5所述的方法，其中，所述大數據系統的Websphere應用服務器WAS模塊通過讀取所述Elasticsearch模塊中各網元的離線日志統計結果，對該網元日志的關鍵性指標數據進行業務質量監控，判斷所述網元日志的關鍵性指標數據是否存在風險，并在判斷所述網元日志關鍵性指標數據存在風險時向運維人員發出數據通信業務質量的預警提示。

8.一種數據通信業務質量監控的大數據系統，包括：

kafka consumer模塊，用于通過對各個網元的話單日志服務器發送的日志數據進行日志處理，得到各網元的日志處理結果和日志統計結果；

Elasticsearch模塊，用于存儲所述日志處理結果和日志統計結果；

WAS模塊，用于根據所述Elasticsearch模塊內存儲的各網元日志處理結果和日志統計結果對該網元日志的關鍵性指標數據進行業務質量監控，判斷所述網元日志的關鍵性指標數據是否存在風險，以及當判斷所述網元日志關鍵性指標數據存在風險，則向運維人員發出數據通信業務質量的預警提示；

其中，所述WAS是指Websphere應用服務器。

9.根據權利要求8所述的大數據系統，還包括：brokers模塊，用于接收部署在每個網元的話單日志服務器中kafka producers模塊收集所在網元的日志數據。

10.根據權利要求9所述的大數據系統，所述brokers模塊具體用于收到來自各個網元編碼后的日志數據后，保存所述各網元編碼后的日志數據，并啟動spark streaming任務調用kafka consumer模塊。