[發明專利]一種流數據處理方法和裝置

在審

• 申請號: 202011216552.8
• 申請日: 2020-11-04
• 公開（公告）號: CN112328660A
• 公開（公告）日: 2021-02-05
• 發明（設計）人: 張順
• 申請（專利權）人: 北京航云物聯信息技術有限公司
• 主分類號: G06F16/2458
• 分類號: G06F16/2458;G06F16/2455;G06F16/22
• 代理公司: 北京鼎承知識產權代理有限公司 11551
• 代理人: 顧可嘉;夏華棟

1.一種流數據處理裝置，其特征在于，該裝置包括：數據采集模塊、數據生成模塊和數據輸出模塊，其中，

所述數據采集模塊，用于采集至少兩個數據流的流數據，以及將每個數據流的流數據發送給所述數據生成模塊；

所述數據生成模塊，用于接收所述數據采集模塊發送的流數據，以及將至少兩個所述數據流的流數據整合為一個或多個流數據元組，并將所述流數據元組發送給所述數據輸出模塊；其中所述流數據元組的元素個數與所述數據流的個數一致；

所述數據輸出模塊，用于接收所述數據生成模塊發送的所述流數據元組，并按照所述數據生成模塊整合的所述流數據元組輸出流數據。

2.根據權利要求1所述流數據處理裝置，其特征在于，所述數據生成模塊具體用于根據所述數據采集模塊采集每個所述數據流中流數據的采集時間，將每個所述數據流中最早采集的流數據整合為當前流數據元組，并將所述當前流數據元組發送給所述數據輸出模塊，并以此重復將所述數據采集模塊采集的流數據發送給所述數據輸出模塊。

3.根據權利要求1所述流數據處理裝置，其特征在于，所述數據生成模塊包括頻率確定單元、數據取舍單元和數據整合單元，其中，

所述頻率確定單元，用于確定所有所述數據流中的主數據流，以及所述主數據流采集數據的主頻率；

所述數據取舍單元，用于對除所述主數據流以外的其他數據流中采集數據的頻率低于所述主頻率的所述數據流進行流數據補償，和\或，對除所述主數據流以外的其他數據流中采集數據的頻率高于所述主頻率的所述數據流進行流數據丟棄；

所述數據整合單元，用于將所述主數據流的流數據與所述數據取舍單元獲得的除所述主數據流以外的其他數據流的流數據整合為流數據元組。

4.根據權利要求1所述流數據處理裝置，其特征在于，所述數據生成模塊包括時間確定單元、數據選取單元和數據成組單元，其中，

所述時間確定單元，用于確定所有所述數據流中的主數據流，以及所有所述數據流中流數據的采集時間；

所述數據選取單元，用于以所述主數據流的采集時間為基準，在剩下的每個所述數據流中選取與所述主數據流的采集時間之間時間間隔最小的流數據；

所述數據成組單元，用于將所述主數據流的流數據與剩下的每個所述數據流中選取的流數據整合為數據元組。

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

采集至少兩個數據流的流數據；

將至少兩個所述數據流的流數據整合為一個或多個流數據元組；其中所述流數據元組的元素個數與所述數據流的個數一致；

按照所述流數據元組輸出至少兩個所述數據流的流數據。

6.根據權利要求5所述流數據處理方法，其特征在于，所述將至少兩個所述數據流的流數據整合為一個或多個流數據元組，包括：

根據每個所述數據流中流數據的采集時間，將每個所述數據流中最早采集的流數據整合為流數據元組。

7.根據權利要求5所述流數據處理方法，其特征在于，所述將至少兩個所述數據流的流數據整合為一個或多個流數據元組，包括：

S1：確定所有所述數據流中的主數據流，以及所述主數據流采集數據的主頻率；

S2：對除所述主數據流以外的其他數據流中采集數據的頻率低于所述主頻率的數據流進行流數據補償，和\或，對除所述主數據流以外的其他數據流中采集數據的頻率高于所述主頻率的數據流進行流數據丟棄；

S3：將所述主數據流的流數據與由S2獲得的數據流的流數據整合為流數據元組。

8.根據權利要求5所述流數據處理方法，其特征在于，所述將至少兩個所述數據流的流數據整合為一個或多個流數據元組，包括：

確定所有所述數據流中的主數據流，以及所有所述數據流中流數據的采集時間；

以所述主數據流的采集時間為基準，在剩下的每個所述數據流中選取與所述主數據流的采集時間之間時間間隔最小的流數據；

將所述主數據流的流數據與剩下的每個所述數據流中選取的流數據整合為流數據元組。