[發明專利]基于storm面向用戶個性化預警機制大數據計算方法

在審

• 申請號: 201710108940.6
• 申請日: 2017-02-27
• 公開（公告）號: CN106951464A
• 公開（公告）日: 2017-07-14
• 發明（設計）人: 張啟亮;王飛;朱曉委;張毅;邵世龍
• 申請（專利權）人: 江蘇徐工信息技術股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;G06F11/30
• 代理公司: 徐州市三聯專利事務所32220
• 代理人: 周愛芳

1.一種基于storm面向用戶個性化預警機制大數據計算方法，其特征在于，包括數據預處理模塊、數據解析模塊、數據存儲模塊和報警處理模塊；

數據預處理模塊包括服務器網關和kafka消息隊列，kafka消息隊列負責服務網關數據與解析數據的橋梁，服務器網關從獲取終端發來的原始數據存入kafka的topic中，作為數據解析模塊處理的生產者；

數據解析模塊為storm解析模塊，負責從kafka的topic中讀取數據，并對topic中的原始數據根據協議定義進行解析；其中，storm的數據處理機制是流式處理，對數據進行逐條解析；

數據存儲模塊包括數據緩存模塊、緩存數據庫更新模塊和歷史報警存儲模塊；

報警處理模塊為storm報警模塊，一方面，從數據緩存模塊中獲取用戶自定義報警方案，另一方面，根據這些報警方案分析出報警邏輯，并且分析出報警結果；

基于storm面向用戶個性化預警機制大數據計算方法的具體步驟是：

步驟一、用戶通過界面按照自身設備設置報警邏輯，設置成功后，系統將會按照約定的數據結構存儲報警邏輯的參數和閾值；

步驟二、數據緩存模塊定時的從數據庫中讀取步驟一中存儲的數據結構，并用于下一步storm報警模塊；其中，定時的時間可由用戶自己設定；

步驟三、storm報警模塊結合從數據緩存模塊讀取報警所需的參數和閾值與服務器網關從終端讀取發來的實時數據進行邏輯判斷；

步驟四、經過步驟三的判斷確定這條數據是否為報警數據，如果是報警數據，將進一步判斷redis中是否已經存在設備的報警歷史，如果存在則更新redis中的相應記錄，如果不存在則向redis中插入一條報警記錄；如果不是報警數據，同樣要判斷redis中的報警歷史，如果存在,表示報警已經解除，則從redis中刪除這條記錄。

2.根據權利要求1所述的一種基于storm面向用戶個性化預警機制大數據計算方法，其特征在于，所述緩存數據庫更新模塊采用緩存技術redis與界面進行實時交互。

3.根據權利要求1所述的一種基于storm面向用戶個性化預警機制大數據計算方法，其特征在于，所述歷史報警存儲模塊采用hadoop的hdfs技術進行分布式存儲。