[發明專利]一種數據處理方法、裝置及系統

在審

• 申請號: 201611248259.3
• 申請日: 2016-12-29
• 公開（公告）號: CN106649140A
• 公開（公告）日: 2017-05-10
• 發明（設計）人: 王剛
• 申請（專利權）人: 深圳前海弘稼科技有限公司
• 主分類號: G06F12/0811
• 分類號: G06F12/0811;G06F12/0842;G06F9/38
• 代理公司: 北京集佳知識產權代理有限公司11227
• 代理人: 羅滿

1.一種數據處理方法，其特征在于，包括：

緩存隊列將各采集設備采集到的采集數據緩存，并在緩存量超過預定數量時，將已緩存的采集數據按照預定規則釋放至各數據處理單元；

各數據處理單元接收釋放的采集數據，分別啟動各自的數據處理線程進行數據處理以得到數據處理結果。

2.根據權利要求1所述的數據處理方法，其特征在于，所述各數據處理單元接收釋放的采集數據，分別啟動各自的數據處理線程進行數據處理以得到數據處理結果具體包括：

實時接收釋放的采集數據，并二次緩存；

判斷是否到達各自的釋放時間；

如果是，則將二次緩存的采集數據全部釋放，并啟動各自的數據處理線程進行數據處理以得到數據處理結果；

如果否，則繼續判斷是否到達各自的釋放時間。

3.根據權利要求2所述的數據處理方法，其特征在于，各所述數據處理單元中的數據處理線程為多個。

4.根據權利要求1所述的數據處理方法，其特征在于，所述將已緩存的采集數據按照預定規則釋放至各數據處理單元具體為：按照先進先出、進一出一的原則釋放已緩存的采集數據，按照各所述數據處理單元當前的處理狀態分配已緩存的采集數據。

5.根據權利要求4所述的數據處理方法，其特征在于，所述按照各所述數據處理單元當前的處理狀態分配已緩存的采集數據具體為：如果有空閑的數據處理單元，則將已緩存的采集數據分配給空閑的數據處理單元，否則，隨機分配。

6.根據權利要求1所述的數據處理方法，其特征在于，還包括：各所述數據處理單元將所述數據處理結果發送給監控服務器。

7.根據權利要求1所述的數據處理方法，其特征在于，還包括：當所述數據處理結果出現異常時對應的數據處理單元輸出報警提示信息，其中所述采集數據中包含有采集設備的身份信息，所述報警提示信息包含對應的采集設備的身份信息。

8.根據權利要求1所述的數據處理方法，其特征在于，還包括：存儲單元存儲各所述數據處理單元的數據處理結果。

9.一種數據處理裝置，其特征在于，包括：

緩存隊列，用于將各采集設備采集到的采集數據緩存，并在緩存量超過預定數量時，將已緩存的采集數據按照預定規則釋放至各數據處理單元；

多個數據處理單元，各數據處理單元用于接收釋放的采集數據，分別啟動各自的數據處理線程進行數據處理以得到數據處理結果。

10.根據權利要求9所述的數據處理裝置，其特征在于，各所述數據處理單元具體包括：

時間緩存流模塊，用于實時接收釋放的采集數據，并二次緩存；判斷是否到達釋放時間；如果是，則將二次緩存的采集數據全部釋放；如果否，則繼續判斷是否到達釋放時間；

流處理模塊，用于啟動自身的數據處理線程進行數據處理以得到數據處理結果。

11.一種數據處理系統，包括各采集設備，監控服務器，其特征在于，還包括權利要求9或10所述的數據處理裝置。