[發明專利]一種車輛實時監控方法

在審

• 申請號: 202011169857.8
• 申請日: 2020-10-28
• 公開（公告）號: CN112288907A
• 公開（公告）日: 2021-01-29
• 發明（設計）人: 連序全;陳乃闊;畢茂華
• 申請（專利權）人: 山東超越數控電子股份有限公司
• 主分類號: G07C5/08
• 分類號: G07C5/08;G07C5/00;G06F16/21;G06F16/22;G06F16/2458;G06N20/00
• 代理公司: 北京連和連知識產權代理有限公司 11278
• 代理人: 劉小峰;陳黎明

1.一種車輛實時監控方法，包括以下步驟：

獲取車輛原始數據并基于Flink計算引擎對車輛原始數據進行處理；

基于HBase實時存儲處理后的車輛數據；

根據存儲的車輛數據，利用機器學習回歸算法訓練預測模型；

將實時數據導入預測模型進行實時預測；

將預測結果和實時數據輸出展示。

2.根據權利要求1所述的方法，其特征在于，所述獲取車輛原始數據包括：

通過物聯網網關以物聯網通信協議的方式獲取車輛狀態數據。

3.根據權利要求1所述的方法，其特征在于，所述基于Flink計算引擎對車輛數據進行處理包括：

對獲取到的車輛數據進行格式轉化、數據過濾、數據聚合、數據統計。

4.根據權利要求3所述的方法，其特征在于，所述基于Flink計算引擎對車輛數據進行處理包括：

利用Flink計算引擎的map算子進行數據預處理，將各類指標統一相同的格式；以及

利用Flink計算引擎的filter算子進行數據清洗，過濾掉不規則的數據；以及

利用Flink計算引擎的window算子進行數據匯總，將實時數據進行窗口范圍的歸并操作；以及

利用Flink計算引擎的reduce算子進行數據統計，將窗口內的數據進行求和或求平均值。

5.根據權利要求1所述的方法，所述基于HBase實時存儲處理后的車輛數據包括：

將處理后車輛數據寫入HBase實時表進行實時數據存儲；

將處理后車輛數據進行離線存儲，構建數據倉庫。

6.根據權利要求5所述的方法，其特征在于，所構建數據倉庫包括：

利用Flink計算引擎的sink接口，編寫GPSink類，將計算的最終結果寫入GP的表中進行離線存儲，構建數據倉庫。

7.根據權利要求1所述的方法，其特征在于，所述利用機器學習回歸算法訓練預測模型包括：

利用機器學習回歸算法，從數據倉庫中獲取歷史數據作為輸入，通過定時調用訓練任務的方式進行訓練。

8.根據權利要求7所述的方法，其特征在于，所述機器學習算法包括：

線性回歸、廣義線性回歸、保序回歸算法。

9.根據權利要求1所述方法，其特征在于，所述實時預測包括：

將車輛實時數據作為輸入，調用模型預測接口函數獲取預測結果，并將結果存儲到HBase的離線表中。

10.根據權利要求1所述的方法，其特征在于，還包括：

將獲取到的車輛原始數據存儲到Kafka組件中。