[發明專利]一種反應式氣動數據多維分析平臺

有效

• 申請號: 202110288497.1
• 申請日: 2021-03-18
• 公開（公告）號: CN113064910B
• 公開（公告）日: 2022-03-08
• 發明（設計）人: 黎茂鋒;劉志勤;駱蓉;馮嬌;李光偉;黃俊;畢國堂
• 申請（專利權）人: 西南科技大學
• 主分類號: G06F16/24
• 分類號: G06F16/24;G06F16/2455;G06F16/248
• 代理公司: 成都正華專利代理事務所(普通合伙) 51229
• 代理人: 李蕊

1.一種反應式氣動數據多維分析平臺，其特征在于，包括通信連接的前端人機交互模塊和后端流式并行高速數據處理模塊；

所述前端人機交互模塊包括分析前置操作單元、分析交互操作單元和分析后置操作單元；

所述分析前置操作單元用于采集用戶選擇的分析方法和用戶確定的氣動數據集ID列表，并向后端流式并行高速數據處理模塊提交，完成分析初始化；

所述分析交互操作單元用于根據分析初始化結果進行前端人機交互模塊和后端流式并行高速數據處理模塊的交互響應，形成UI部件；

所述分析后置操作單元用于保存和下載分析交互操作的結果；

所述后端流式并行高速數據處理模塊用于根據分析前置操作單元提交的用戶選擇的分析方法和用戶確定的氣動數據集ID列表，進行map化并行流式操作，并用于和用戶選擇的分析方法和用戶確定的氣動數據集ID列表實現交互響應；

所述反應式氣動數據多維分析平臺包括初始數據查詢單元、數據庫與有效域和初始數據響應單元；

所述分析前置操作單元包括會話記錄單元和UI部件構建單元；

所述后端流式并行高速數據處理模塊包括數據預處理單元、分析會話空間和map化數據緩存單元與領域對象數據緩存單元；

所述前端人機交互模塊和后端流式并行高速數據處理模塊通過初始數據查詢單元與有效域和初始數據響應單元實現通信；

所述數據預處理單元與分析會話空間和map化數據緩存單元通過會話空間創建和領域對象map化操作實現通信；

所述會話記錄單元用于記錄用戶選擇的分析方法和用戶確定的氣動數據集ID列表；

所述初始數據查詢單元用于向數據預處理單元提交氣動數據查詢請求；

所述數據預處理單元用于從領域對象數據緩存單元中獲取每個氣動數據集ID列表對應的具體氣動數據，若領域對象數據緩存單元中無對應氣動數據，則向數據庫查詢并保存在領域對象數據緩存單元中；

所述分析會話空間和map化數據緩存單元用于根據初始數據查詢單元的提交結果創建內存空間，并對氣動數據進行形式轉換；

所述有效域和初始數據響應單元用于提取有效域名稱和初始數據分頁；

所述UI部件構建單元根據會話記錄單元中記錄的分析方法、有效域名稱和初始數據分頁，構建前端人機交互模塊中用戶分析界面的UI部件；

所述有效域和初始數據響應單元的操作包括依次進行的有效域提取和初始數據分頁提取；

所述有效域提取包括以下子步驟：

A1：通過并行流化機制將map化的氣動數據轉變為若干個并行流；

A2：對每個并行流進行flat map，將氣動數據的數據域扁平化到流中；

A3：對所有數據域進行過濾，并利用map映射取出域名稱，形成域名稱流；

A4：利用distinct去除多余值的域名稱流，并進行若干個流的合并形成域名稱集合，完成有效域名稱提取；

所述初始數據分頁提取包括以下子步驟：

B1：將map化的氣動數據流化形成Map結構的氣動數據流；

B2：對氣動數據流依次進行skiplimit過程和map過程；

B3：基于skiplimit過程和map過程后的氣動數據，收集RedundancedAerodataStream，并與分頁信息組合得到分頁載荷數據，完成初始數據分頁；

所述步驟B2中，進行map過程的方法為：流化Map結構的單個Aerodata，并根據提取的有效域名稱進行過濾，得到有效域數據，將有效域數據重新組裝，取出多余域的氣動數據。

2.根據權利要求1所述的反應式氣動數據多維分析平臺，其特征在于，所述初始數據查詢單元包括三個參數，分別為{session:x,type:y,datasets[a,b,...]}；

其中，session為會話記錄單元隨機生成不重復字串來標識分析會話，用于前端人機交互模塊和后端流式并行高速數據處理模塊中相同分析會話的數據暫存和同步協調，當用戶重新選擇分析類型和用戶保存分析時，session值會重新生成并傳到后端流式并行高速數據處理模塊進行更新；

type為用戶選定的分析方法，分析法包含單分量分析、多分量分析、誤差分析、統計分析、二元分析、多元分析和包絡線分析，用于傳到后端流式并行高速數據處理模塊中確定特定分析函數的選擇；

datasets[a,b,...]為氣動數據集ID列表的ID集合[a,b,...]。