[發(fā)明專利]航班運行數(shù)據(jù)報文解析系統(tǒng)及方法

有效

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

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

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

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

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

所述報文數(shù)據(jù)監(jiān)控管理模塊(4)根據(jù)報文采集識別成功與否的消息、解析成功與否的消息和匹配結(jié)果消息進行數(shù)據(jù)統(tǒng)計和標(biāo)記，根據(jù)報文數(shù)據(jù)生成全文索引，實現(xiàn)對報文數(shù)據(jù)全文檢索；

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

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

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

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

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

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

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

S4：報文數(shù)據(jù)監(jiān)控管理模塊(4)根據(jù)報文采集識別成功與否的消息、解析成功與否的消息和匹配結(jié)果消息進行數(shù)據(jù)統(tǒng)計和標(biāo)記，根據(jù)報文數(shù)據(jù)生成全文索引，實現(xiàn)對報文數(shù)據(jù)全文檢索；

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

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

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