[發(fā)明專利]航天測控數(shù)據(jù)實時入庫方法

在審

• 申請?zhí)枺?/td>: 202110533534.0
• 申請日: 2021-05-17
• 公開（公告）號: CN113297216A
• 公開（公告）日: 2021-08-24
• 發(fā)明（設(shè)計）人: 孟彥鵬;張獻;王兆巖;崔金;李曉琳
• 申請（專利權(quán)）人: 中國人民解放軍63920部隊
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/25
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 單曉雙;葉明川

本發(fā)明提供一種航天測控數(shù)據(jù)實時入庫方法，包括：接收電文數(shù)據(jù)和文件數(shù)據(jù)；將所述電文數(shù)據(jù)和所述文件數(shù)據(jù)緩存至Kafka消息中間件中得到緩存數(shù)據(jù)；按照預設(shè)的配置信息對所述緩存數(shù)據(jù)進行解析處理，將解析得到的數(shù)據(jù)按類型存儲至預設(shè)的獨立緩存中；其中，所述獨立緩存是根據(jù)數(shù)據(jù)表中每個字段申請的獨立的緩存；在解析處理完畢后，調(diào)用數(shù)據(jù)庫接口將獨立緩存中存儲的數(shù)據(jù)存儲至數(shù)據(jù)庫中，本發(fā)明能夠?qū)崿F(xiàn)航天測控數(shù)據(jù)的實時解析入庫，具有入庫實時性高、擴展性強和安全性可靠性高的有益效果。

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)庫處理技術(shù)領(lǐng)域，具體涉及一種航天測控數(shù)據(jù)實時入庫方法。

背景技術(shù)

隨著航天技術(shù)的發(fā)展，大型航天器的在軌運行時間、測控通信覆蓋率、信息傳輸量、傳輸頻率與以往相比，都有了數(shù)量級的增加，這給測控數(shù)據(jù)的存儲帶來了空前的挑戰(zhàn)。大量的任務數(shù)據(jù)對于航天器狀態(tài)的判讀、測控資源的管理與調(diào)配以及測控任務實施過程中決策分析等都具有重要作用，但許多有用的、可提供決策的歷史信息由于入庫實時性不高，無法滿足日益復雜多樣的任務分析需求與數(shù)據(jù)服務需求。

因此，現(xiàn)有的數(shù)據(jù)入庫系統(tǒng)還存在不能滿足實時性要求的技術(shù)問題

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

針對現(xiàn)有技術(shù)中的問題，本發(fā)明提供一種航天測控數(shù)據(jù)實時入庫方法，能夠?qū)崿F(xiàn)航天測控數(shù)據(jù)的實時解析入庫。

為解決上述技術(shù)問題，本發(fā)明提供以下技術(shù)方案：

本發(fā)明提供一種航天測控數(shù)據(jù)實時入庫方法，包括：

接收電文數(shù)據(jù)和文件數(shù)據(jù)；

將所述電文數(shù)據(jù)和所述文件數(shù)據(jù)緩存至Kafka消息中間件中得到緩存數(shù)據(jù)；

按照預設(shè)的配置信息對所述緩存數(shù)據(jù)進行解析處理，將解析得到的數(shù)據(jù)按類型存儲至預設(shè)的獨立緩存中；其中，所述獨立緩存是根據(jù)數(shù)據(jù)表中每個字段申請的獨立的緩存；

在解析處理完畢后，調(diào)用數(shù)據(jù)庫接口將獨立緩存中存儲的數(shù)據(jù)存儲至數(shù)據(jù)庫中。

進一步地，在所述接收電文數(shù)據(jù)和文件數(shù)據(jù)之后，還包括：

對所述電文數(shù)據(jù)和所述文件數(shù)據(jù)進行封裝處理得到封裝數(shù)據(jù)；

將所述封裝數(shù)據(jù)緩存至Kakfa消息中間件中得到緩存數(shù)據(jù)。

進一步地，在所述接收電文數(shù)據(jù)和文件數(shù)據(jù)之前，還包括：

讀取電文數(shù)據(jù)的訂閱配置信息和文件數(shù)據(jù)的訂閱配置信息；

根據(jù)航天器任務碼、目標碼信息設(shè)定Kafka主題，初始化Kafka連接并啟動接收線程和推送Kafka線程。

其中，所述配置信息包括：電文數(shù)據(jù)的字段結(jié)構(gòu)定義、文件數(shù)據(jù)的字段結(jié)構(gòu)定義和航天測控參數(shù)定義。

其中，所述數(shù)據(jù)表的字段包括：表名、所屬數(shù)據(jù)庫IP、端口、時間約束參數(shù)、記錄條目約束參數(shù)和記錄大小約束參數(shù)。

其中，所述對所述緩存數(shù)據(jù)進行解析處理，包括：

根據(jù)航天器任務碼、目標碼信息從相應Kakfa主題中獲取緩存數(shù)據(jù)，按照緩存數(shù)據(jù)的結(jié)構(gòu)定義，對所述緩存數(shù)據(jù)進行逐個字段解析處理。

其中，還包括：

將所述電文數(shù)據(jù)和所述文件數(shù)據(jù)放入全局消息隊列進行緩存。