[發明專利]一種埋點數據的計算方法、裝置、存儲介質和電子設備

在審

• 申請號: 202110282866.6
• 申請日: 2021-03-16
• 公開（公告）號: CN113010382A
• 公開（公告）日: 2021-06-22
• 發明（設計）人: 吳輝;江敏
• 申請（專利權）人: 杭州數瀾科技有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F16/17
• 代理公司: 北京市聯德律師事務所 11361
• 代理人: 黃大正;張來光

1.一種埋點數據的計算方法，包括：

將采集到的埋點數據進行劃分，得到多個數據分片，每個數據分片攜帶有唯一標識信息；

將所述多個數據分片分配給多個計算任務執行計算，得到與所述多個數據分片分別對應的多個計算結果；

基于所述多個數據分片中的每個數據分片所攜帶的唯一標識信息，確定采集來源相同的數據分片；以及

將所述多個計算結果中所述采集來源相同的數據分片所對應的計算結果發送給同一個匯總節點進行合并處理。

2.如權利要求1所述的方法，其中所述唯一標識信息中包括采集來源，以及相對于該采集來源，按照采集時間順序為所述唯一標識信息對應的數據分片分配的分片序號。

3.如權利要求2所述的方法，其中所述將所述多個計算結果中所述采集來源相同的數據分片所對應的計算結果發送給同一個匯總節點進行合并處理，包括：

根據所述分片序號，將對應的計算結果重新排序；以及

將排序后的計算結果發送給同一個匯總節點進行合并處理，得到所述采集來源的具有時間連續性的計算結果。

4.如權利要求1所述的方法，其中所述合并處理前，還包括：對所述計算結果進行去重處理。

5.如權利要求1所述的方法，其中所述采集來源包括：產生所采集埋點數據的用戶。

6.如權利要求1所述的方法，其中所述數據分片還攜帶有采樣頻率、分片大小、采樣開始時間、采樣點數和采樣數據集中的一項或多項信息。

7.如權利要求1所述的方法，其中所述多個計算任務在執行計算時是并行的。

8.如權利要求1所述的方法，其中所述多個計算任務執行所述計算時，至少對所述多個數據分片執行信號去噪處理和波形檢測提取處理。

9.如權利要求1所述的方法，其中所述波形檢測提取處理時使用差分閾值檢測法、數學形態學法、小波變換法或神將網絡法中的至少一項。

10.一種埋點數據的計算裝置，包括：

數據劃分模塊，被配置為將采集到的埋點數據進行劃分，得到多個數據分片，每個數據分片攜帶有唯一標識信息；

數據分配模塊，被配置為將所述多個數據分片分配給多個計算任務執行計算，得到與所述多個數據分片分別對應的多個計算結果；

數據識別模塊，被配置為基于所述多個數據分片中的每個數據分片所攜帶的唯一標識信息，確定采集來源相同的數據分片；以及

數據合并模塊，被配置為將所述多個計算結果中所述采集來源相同的數據分片所對應的計算結果發送給同一個匯總節點進行合并處理。

11.如權利要求10所述的裝置，其中所述唯一標識信息中包括采集來源，以及相對于該采集來源，按照采集時間順序為所述唯一標識信息對應的數據分片分配的分片序號。

12.如權利要求11所述的裝置，其中所述數據合并模塊，在將所述多個計算結果中所述采集來源相同的數據分片所對應的計算結果發送給同一個匯總節點進行合并處理時，還被配置為：

根據所述分片序號，將對應的計算結果重新排序；以及

將排序后的計算結果發送給同一個匯總節點進行合并處理，得到所述采集來源的具有時間連續性的計算結果。

13.如權利要求10所述的裝置，還包括數據去重模塊，其被配置為在所述合并處理前，對所述計算結果進行去重處理。

14.如權利要求10所述的裝置，其中所述采集來源包括：產生所采集埋點數據的用戶。

15.如權利要求10所述的裝置，其中所述數據分片還攜帶有采樣頻率、分片大小、采樣開始時間、采樣點數和采樣數據集中的一項或多項信息。