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

在審

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

本申請提供一種埋點數據的計算方法、裝置、存儲介質和電子設備。先將采集到的埋點數據進行劃分和標識，再將劃分出的數據分片自動分配給不同的計算任務執行計算，最后根據各個數據分片的標識將同一采集來源的多個計算結果進行合并計算。該方法在同一時間能計算多個數據分片，提高了計算效率，且支持對多個采集來源的埋點數據同時進行計算。

技術領域

本發明涉及數據處理技術，更具體而言，涉及一種埋點數據的計算方法、裝置、存儲介質和電子設備。

背景技術

埋點是指對目標事件進行捕獲、處理和上報的相關技術及實施過程。具體來說，埋點就是在定義的事件代碼中植入一段用于監控的代碼，這段用于監控的代碼也可被稱為埋點代碼。用戶一旦觸發所定義的事件就會上報埋點代碼中定義的需要上報的字段信息，這些被上報的字段信息可以被稱為埋點數據。通常來說，埋點可以用來監控用戶都打開了哪些頁面，點擊了哪些按鈕，停留了多長時間，等等。

在得到上報的埋點數據后，還需要對埋點數據進行計算，以得到最終的可用數據。傳統方案通常使用單臺機器對埋點信號進行解析計算。由于單臺機器的內存和計算能力有限，同一時間只能對一小部分埋點數據進行計算，不能及時得到計算結果。

發明內容

依據本申請的第一方面，提供了一種埋點數據的計算方法，包括：

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

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

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

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

依據本申請的第二方面，提供了一種埋點數據的計算裝置，包括：

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

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

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

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

依據本申請的第三方面，還提供一種電子設備，包括：處理器；用于存儲所述處理器可執行指令的存儲器；其中，所述處理器被配置為能夠執行所述指令，以實現如第一方面所述的方法。

依據本申請的第四方面，還提供了一種計算機可讀介質，其上存儲有計算機可讀指令，所述計算機可讀指令被計算機執行時能夠執行如第一方面所述的方法。

本申請的實施例能夠在同一時間分別計算大量埋點數據形成的多個數據分片，支持多位用戶同時計算，效率較高。且能保證埋點數據的計算結果的連續性。

附圖說明

圖1是本申請一示例性實施例示出的埋點數據的計算方法的一種流程圖；

圖2是本申請一示例性實施例示出的實時采集的一種流程圖；

圖3是本申請一示例性實施例示出的數據分片過程的一種示意圖；

圖4是本申請一示例性實施例示出的埋點信號的一種示意圖；

圖5是本申請一示例性實施例示出的埋點數據的計算方法的另一種流程圖；