[發(fā)明專利]一種基于流式框架的CORS預警監(jiān)控系統

在審

• 申請?zhí)枺?/td>: 202010812002.6
• 申請日: 2020-08-13
• 公開（公告）號: CN112116790A
• 公開（公告）日: 2020-12-22
• 發(fā)明（設計）人: 馮潤威;張晉升;李海良;羅澤彬
• 申請（專利權）人: 廣州市中海達測繪儀器有限公司
• 主分類號: G08B21/18
• 分類號: G08B21/18;G08B25/10
• 代理公司: 廣州市越秀區(qū)哲力專利商標事務所(普通合伙) 44288
• 代理人: 謝嘉舜

1.一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：包括數據采集模塊、消息隊列、開源分布式計算框架模塊、數據存儲模塊以及預警模塊，所述數據采集模塊與所述消息隊列連接，所述消息隊列與所述開源分布式計算框架模塊連接，所述開源分布式計算框架模塊分別與所述數據存儲模塊以及所述預警模塊連接，所述數據存儲模塊包括Redis存儲單元、Hbase存儲單元以及Elasticsearch存儲單元，所述Redis存儲單元、所述Hbase存儲單元以及所述Elasticsearch存儲單元均與所述開源分布式計算框架模塊連接；

所述數據采集模塊實時采集CORS服務系統中的原始數據，所述數據采集模塊將所述原始數據發(fā)送至所述消息隊列，所述開源分布式計算框架模塊通過所述消息隊列模快獲取所述原始數據，所述開源分布式計算框架模塊對所述原始數據進行計算統計處理得到第一統計結果，所述開源分布式計算框架模塊根據預設分流策略將所述原始數據分流存儲至所述Redis存儲單元或所述Hbase存儲單元或所述Elasticsearch存儲單元，所述開源分布式計算框架模塊根據預設監(jiān)控策略對所述原始數據進行監(jiān)控處理并得到監(jiān)控結果，當所述監(jiān)控結果為異常時，所述開源分布式計算框架模塊生成第一告警信息并將所述第一告警信息發(fā)送至所述預警模塊，所述預警模塊將所述第一告警信息發(fā)送至運維人員。

2.如權利要求1所述的一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：所述開源分布式計算框架模塊包括計算統計單元、數據分流單元以及數據監(jiān)測單元，所述數據分流單元分別與所述Redis存儲單元、所述Hbase存儲單元以及所述Elasticsearch存儲單元連接，所述數據監(jiān)測單元與所述預警模塊連接，所述計算統計單元用于對所述原始數據進行計算統計處理得到第一統計結果，所述數據分流單元用于根據預設分流策略將所述原始數據分流存儲至所述Redis存儲單元或所述Hbase存儲單元或所述Elasticsearch存儲單元，所述數據監(jiān)測單元用于根據預設監(jiān)控策略對所述原始數據進行監(jiān)控處理并得到監(jiān)控結果，當所述監(jiān)控結果為異常時，所述數據監(jiān)測單元生成第一告警信息并將所述第一告警信息發(fā)送至所述預警模塊。

3.如權利要求2所述的一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：所述數據分流單元包括第一連接器、第二連接器以及第三連接器，所述第一連接器與Redis存儲單元連接，所述第二連接器與所述Hbase存儲單元連接，所述第三連接器與所述Elasticsearch存儲單元連接。

4.如權利要求2所述的一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：還包括策略引擎模塊，所述策略引擎模塊包括策略管理單元和策略池，所述策略管理單元與所述策略池連接，所述策略池分別與所述數據分流單元和所述數據監(jiān)測單元連接，所述策略池中存儲有預設分流策略和預設監(jiān)控策略，所述數據分流單元通過所述策略池獲取預設分流策略，所述數據監(jiān)測單元通過所述策略池獲取預設監(jiān)控策略。

5.如權利要求4所述的一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：所述策略管理單元與所述數據存儲模塊連接，所述策略管理單元根據所述數據存儲模塊中所有原始數據進行數據預測分析，得到分析結果，所述策略管理單元根據所述分析結果對所述策略池中的預設監(jiān)控策略進行更新處理。

6.如權利要求4所述的一種基于流式框架的CORS預警監(jiān)控系統，其特征在于：還包括數據視圖模塊，所述數據視圖模塊包括設置策略單元、預警顯示單元和統計顯示單元，所述預警顯示單元與所述數據監(jiān)測單元連接，所述統計顯示單元與所述計算統計單元連接，所述設置策略單元與所述策略管理單元連接，所述計算統計單元將所述第一統計結果發(fā)送至所述統計單元，所述統計顯示單元根據所述第一統計結果進行統計顯示，所述數據監(jiān)測單元將第一告警信息發(fā)送至所述預警顯示單元進行告警顯示，所述設置策略單元通過所述策略管理單元設置所述策略池中的預設分流策略和預設監(jiān)控策略。