[發明專利]航班運行數據報文解析系統及方法

有效

• 申請號: 201911072617.3
• 申請日: 2019-11-05
• 公開（公告）號: CN111030989B
• 公開（公告）日: 2021-10-29
• 發明（設計）人: 王宇中;劉德永
• 申請（專利權）人: 北京恒贏智航科技有限公司;北京三贏偉業科技有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;G06Q50/30;G06F16/27;G06F16/2455;G06F16/23;G06F9/54
• 代理公司: 廣州粵高專利商標代理有限公司 44102
• 代理人: 林麗明

1.航班運行數據報文解析系統，其特征在于：包括報文采集模塊(1)、報文解析模塊(2)、報文預處理匹配模塊(3)和報文數據監控管理模塊(4)，其中：

所述報文采集模塊(1)用于對報文數據的采集分類與存儲，并將分類后的報文數據和采集識別成功消息傳輸至所述報文解析模塊(2)，發送報文采集識別成功與否的消息給報文數據監控管理模塊(4)；

所述報文解析模塊(2)用于報文數據的解析，并將解析到的數據和解析成功消息發送至所述報文預處理匹配模塊(3)，發送解析成功與否的消息至報文數據監控管理模塊(4)；

所述報文預處理匹配模塊(3)根據航班計劃中的信息和解析到的數據進行驗證、匹配運算，得到最佳的航班并將匹配結果消息發送至所述報文數據監控管理模塊(4)；

所述報文數據監控管理模塊(4)根據報文采集識別成功與否的消息、解析成功與否的消息和匹配結果消息進行數據統計和標記，根據報文數據生成全文索引，實現對報文數據全文檢索；

所述報文采集模塊(1)采用集群進行部署，通過分布式鎖機制zookeeper協調多個采集節點對數據源進行報文數據采集分類，并將分類后的數據進行儲存；最后發送含有報文數據結構的采集識別成功消息至所述報文解析模塊(2)；最終將報文采集識別是否成功、采集識別開始時間、采集識別結束時間信息作為報文采集識別成功與否的消息發送至所述報文數據監控管理模塊(4)；

所述報文解析模塊(2)上設置有規則引擎QLExpress和MongoDB數據庫；所述報文解析模塊(2)在系統啟動時加載報文解析規則并定時更新或者手動觸發加載更新解析規則，當收到采集識別成功消息時，根據報文解析規則和規則引擎QLExpress解析出分類后的報文數據的鍵值對，將解析成功生成的鍵值對和采集識別成功消息組合成的JSON格式數據存入報文類別集合的MongoDB數據庫中，同時JSON數據作為解析成功消息發送給報文預處理匹配模塊(3)；最后對收到的采集識別成功消息追加報文解析開始時間、解析結束時間，作為解析成功與否的消息發送至所述報文數據監控管理模塊(4)；

當所述報文預處理匹配模塊(3)接收到解析成功消息時，讀取消息中的解析結果，其中包含的航班起飛降落地址、航班號、承運人及報文生成時間推算航班日期，航班起飛降落時間數值類根據需要采用范圍匹配，匹配航班計劃中的航班信息，并根據航班中的信息和解析到的數據算出最佳的航班；最后在解析成功消息追加匹配開始時間、匹配結束時間和航班ID，作為匹配結果消息發送至所述報文數據監控管理模塊(4)。

2.航班運行數據報文解析方法，其特征在于，包括以下步驟：

S1：報文采集模塊(1)采集報文數據并進行分類與存儲，并將分類后的報文數據和采集識別成功消息傳輸至所述報文解析模塊(2)，將采集識別成功與否消息傳輸至所述報文數據監控管理模塊(4)；

S2：報文解析模塊(2)對報文數據進行解析及結果存儲，并將解析到的數據和解析成功消息發送至報文預處理匹配模塊(3)，發送解析成功與否消息至報文數據監控管理模塊(4)；

S3：報文預處理匹配模塊(3)根據航班中的信息和解析到的數據進行匹配運算，得到最佳的航班并將匹配結果消息發送至報文數據監控管理模塊(4)；

S4：報文數據監控管理模塊(4)根據報文采集識別成功與否的消息、解析成功與否的消息和匹配結果消息進行數據統計和標記，根據報文數據生成全文索引，實現對報文數據全文檢索；

在所述步驟S1中，報文采集模塊(1)采用集群進行部署，通過分布式鎖機制zookeeper協調多個采集節點對數據源進行報文數據采集分類，并將分類后的數據進行儲存；最后發送含有報文數據結構，如果是大報文，為包含報文存儲地址數據結構的采集識別成功通知消息至報文解析模塊(2)；最終將報文采集識別是否成功、采集識別開始時間、采集識別結束時間信息作為報文采集識別成功與否的消息發送至所述報文數據監控管理模塊(4)；

在所述步驟S2中，報文解析模塊(2)在系統啟動時加載報文解析規則并定時更新或者手動觸發加載解析規則，當收到采集識別成功消息時，根據報文解析規則和設置在報文解析模塊(2)上的規則引擎QLExpress解析出分類后的報文數據的鍵值對，并將生成的鍵值對數據以及其他相關數據組合生成的JSON格式數據，一并存入設置在報文解析模塊(2)上用于存儲報文類別集合的MongoDB數據庫中，同時JSON數據作為解析成功消息發送給報文預處理匹配模塊(3)；最后對收到的采集識別成功消息追加報文解析開始時間、解析結束時間，作為解析成功與否的消息發送至所述報文數據監控管理模塊(4)；

在所述步驟S3中，當報文預處理匹配模塊(3)接收到解析成功消息時，如果消息中包含解析結果地址，則讀取MongoDB數據庫中的JSON文件，否則讀取消息中解析結果JSON，根據JSON數據中包含的航班起飛降落地址、航班號、承運人及報文生成時間推算航班日期，航班起飛降落時間數值類根據需要采用范圍匹配，匹配航班計劃中的航班信息，并根據航班中的信息和解析到的數據算出最佳的航班；最后在解析成功消息追加匹配開始時間、匹配結束時間和航班ID，作為匹配結果消息發送至報文數據監控管理模塊(4)。