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

在審

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

本發(fā)明提供的一種基于流式框架的CORS預警監(jiān)控系統(tǒng)，包括數(shù)據(jù)采集模塊、消息隊列、開源分布式計算框架模塊、數(shù)據(jù)存儲模塊以及預警模塊，數(shù)據(jù)采集模塊與消息隊列連接，消息隊列與開源分布式計算框架模塊連接，開源分布式計算框架模塊分別與數(shù)據(jù)存儲模塊以及預警模塊連接，數(shù)據(jù)存儲模塊包括Redis存儲單元、Hbase存儲單元以及Elasticsearch存儲單元，Redis存儲單元、Hbase存儲單元以及Elasticsearch存儲單元均與開源分布式計算框架模塊連接。本發(fā)明提供的一種基于流式框架的CORS預警監(jiān)控系統(tǒng)，使整個CORS預警監(jiān)控系統(tǒng)可以同時處理海量數(shù)據(jù)并保證監(jiān)控告警具有較高的實時性。

技術領域

本發(fā)明涉及衛(wèi)星導航領域，尤其涉及一種基于流式框架的CORS預警監(jiān)控系統(tǒng)。

背景技術

隨著全球衛(wèi)星定位技術的發(fā)展，定位服務的精度在不斷提升，大規(guī)模的應用場景和海量用戶的使用正在發(fā)生，如基礎測繪、無人駕駛、無人機等領域等都需要高精度的位置信息，“全國一張網(wǎng)”的數(shù)據(jù)中心概念已得到實現(xiàn)，但是隨著業(yè)務的發(fā)展，全國基站數(shù)量年年攀升，CORS服務系統(tǒng)迎來大并發(fā)以及海量數(shù)據(jù)的挑戰(zhàn)，為保證關鍵業(yè)務持續(xù)穩(wěn)定和高效的運行，對于CORS服務系統(tǒng)的監(jiān)控和預警必須提升查詢實時性，精確性，能讓運維人員快速定位到故障根源。

目前傳統(tǒng)的CORS服務系統(tǒng)在大數(shù)據(jù)的監(jiān)控中會出現(xiàn)延遲，會因為CORS服務系統(tǒng)中的某個格點沒有差分服務或者某個基站掉線，而沒有及時報警，另外并沒有實時為運維人員提供準確統(tǒng)計分析數(shù)據(jù)，查找問題的根源，無法應對CORS服務系統(tǒng)中的隨著數(shù)據(jù)規(guī)模劇增，導致的系統(tǒng)擴展性和性能問題，包括分庫分表也不能很好的解決，讀寫隨著數(shù)據(jù)的劇增也會變慢，加上關系型數(shù)據(jù)庫在數(shù)據(jù)結(jié)構(gòu)變化時需要停機維護，空列浪費存儲空間。因此，現(xiàn)有的對于CORS服務系統(tǒng)的預警監(jiān)控系統(tǒng)的使用在面對海量數(shù)據(jù)時具有局限性且預警和監(jiān)控的實時性較低。

發(fā)明內(nèi)容

為了克服現(xiàn)有技術的不足，本發(fā)明的目的在于提供一種基于流式框架的CORS預警監(jiān)控系統(tǒng)，其能解決現(xiàn)有CORS服務預警監(jiān)控系統(tǒng)在面對海量數(shù)據(jù)時具有局限性且預警和監(jiān)控的實時性較低的問題。

本發(fā)明的目的采用以下技術方案實現(xiàn)：

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

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