[發明專利]一種分布式智能網聯汽車數據處理系統架構

在審

• 申請號: 202310321850.0
• 申請日: 2023-03-29
• 公開（公告）號: CN116483830A
• 公開（公告）日: 2023-07-25
• 發明（設計）人: 楊雄基;孫超;李德海;徐亮;胡靜;趙貴權
• 申請（專利權）人: 深圳市未來智能網聯交通系統產業創新中心
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/27;G06F16/2455;G06F16/28;G06F16/2458
• 代理公司: 北京科領智誠知識產權代理事務所(普通合伙) 11782
• 代理人: 呂夢雪

1.一種分布式智能網聯汽車數據處理系統架構，其特征在于，包括：數據網關單元、消息列隊單元、數據匯集和傳輸單元、分布式大數據存儲單元、離線計算服務單元、關系型數據庫管理單元和第一分布式實時計算服務單元；

所述消息隊列單元，用于從所述數據網關單元中收集智能網聯汽車數據，并在內部進行分區緩存；

所述數據匯集和傳輸單元，用于從所述消息隊列單元中讀取存儲的智能網聯汽車數據，并將從所述消息隊列單元中讀取的智能網聯汽車數據發送給所述分布式大數據存儲單元進行分布式存儲；

所述離線計算服務單元，用于從所述分布式大數據存儲單元中讀取存儲的智能網聯汽車數據；對從所述分布式大數據存儲單元中讀取的智能網聯汽車數據，結合大數據分析與機器學習AI技術進行離線分析計算，并將離線分析計算結果保存到所述關系型數據庫管理單元；

所述第一分布式實時計算服務單元，用于從所述消息隊列單元中讀取存儲的智能網聯汽車數據；對從所述消息隊列單元中讀取的智能網聯汽車數據進行實時計算，并將實時計算處理結果保存到所述關系型數據庫管理單元。

2.根據權利要求1所述的系統架構，其特征在于，所述系統架構還包括：第二分布式實時計算服務單元和分布式內存型數據存儲單元；

所述第二分布式實時計算服務單元，用于從所述消息隊列單元中讀取存儲的智能網聯汽車數據；將從所述消息隊列單元中讀取的智能網聯汽車數據按照以車輛為管理單位和按照數據采集時間順序依次記錄保存到所述分布式內存型數據存儲單元中；

所述第一分布式實時計算服務單元，還用于從所述分布式內存型數據存儲單元中讀取存儲的智能網聯汽車數據；對從所述分布式內存型數據存儲單元中讀取的智能網聯汽車數據進行實時計算，并將實時計算處理結果保存到所述關系型數據庫管理單元。

3.根據權利要求2所述的系統架構，其特征在于，

所述第一分布式實時計算服務單元，具體用于從所述分布式內存型數據存儲單元中讀取存儲的智能網聯汽車數據；利用算法引擎構建算法規則，結合深度學習AI技術根據數據采集時間和所述算法規則，對從所述分布式內存型數據存儲單元中讀取的智能網聯汽車數據進行實時計算，得到異常狀態告警數據；將所述異常狀態告警數據保存到所述關系型數據庫管理單元中形成汽車異常狀態告警記錄；根據所述異常狀態告警記錄，生成異常告警工單，并將所述異常告警工單推送到智能網聯汽車監控業務平臺。

4.根據權利要求2所述的系統架構，其特征在于，

所述第一分布式實時計算服務單元，還用于從所述分布式內存型數據存儲單元中讀取實時狀態數據，以及從所述關系型數據庫管理單元中讀取靜態數據；利用深度學習AI技術對所述實時狀態數據和所述靜態數據進行運算分析，得到實時狀態報表和統計數據，并將所述實時狀態報表和所述統計數據保存到所述關系型數據庫管理單元中。

5.根據權利要求1所述的系統架構，其特征在于，

所述離線計算服務單元，具體用于對從所述分布式大數據存儲單元中讀取的智能網聯汽車數據進行計算重組，得到重組數據；根據車輛識別碼和時間信息，將所述重組數據保存到相應文件中；對所述相應文件中的重組數據定期進行合并，得到合并數據；每隔預設時間間隔生成每輛智能網聯汽車的日報表數據，并將所述日報表數據保存到所述關系型數據庫管理單元中。

6.根據權利要求5所述的系統架構，其特征在于，

所述離線計算服務單元，還具體用于定期清除重復數據，其中，在生成所述重組數據和所述日報表數據之后，刪除從所述分布式大數據存儲單元中讀取的智能網聯汽車數據，在生成所述合并數據之后，刪除所述重組數據。

7.根據權利要求1所述的系統架構，其特征在于，

所述分布式大數據存儲單元，用于對獲取的智能網聯汽車數據進行序列化處理，得到序列化處理后的智能網聯汽車數據；對所述序列化處理后的智能網聯汽車數據進行壓縮存儲，其中，所述智能網聯汽車數據的記錄中包括車輛型號、車輛識別碼和數據采集時間。