[發明專利]航天測控數據實時入庫方法

在審

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

1.一種航天測控數據實時入庫方法，其特征在于，包括：

接收電文數據和文件數據；

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

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

在解析處理完畢后，調用數據庫接口將獨立緩存中存儲的數據存儲至數據庫中。

2.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，在所述接收電文數據和文件數據之后，還包括：

對所述電文數據和所述文件數據進行封裝處理得到封裝數據；

將所述封裝數據緩存至Kafka消息中間件中得到緩存數據。

3.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，在所述接收電文數據和文件數據之前，還包括：

讀取電文數據的訂閱配置信息和文件數據的訂閱配置信息；

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

4.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，所述配置信息包括：電文數據的字段結構定義、文件數據的字段結構定義和航天測控參數定義。

5.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，所述數據表的字段包括：表名、所屬數據庫IP、端口、時間約束參數、記錄條目約束參數和記錄大小約束參數。

6.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，所述對所述緩存數據進行解析處理，包括：

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

7.根據權利要求1所述的航天測控數據實時入庫方法，其特征在于，還包括：

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