[發明專利]數據統計方法及裝置

有效

• 申請號: 201811119962.3
• 申請日: 2018-09-25
• 公開（公告）號: CN109345300B
• 公開（公告）日: 2022-04-29
• 發明（設計）人: 胡文毅
• 申請（專利權）人: 創新先進技術有限公司
• 主分類號: G06Q30/02
• 分類號: G06Q30/02
• 代理公司: 北京國昊天誠知識產權代理有限公司 11315
• 代理人: 朱文杰

本說明書一個或多個實施例公開了一種數據統計方法及裝置，用以實現在分布式系統中統計數據時能夠同時保障系統的吞吐量及并發數據結果的準確性。所述方法應用于分布式系統，包括：獲取當前統計周期內的目標數據的第一數據累計量；及，根據所述第一數據累計量，執行計算所述當前統計周期內的第一數據消費量的步驟；在執行計算所述第一數據消費量的過程中，若并發產生了所述目標數據，則將并發產生的所述目標數據的數據量累加至所述第一數據累計量中，得到第二數據累計量；根據所述第二數據累計量確定所述當前統計周期內的實際數據消費量；根據所述實際數據消費量生成所述當前統計周期的數據統計結果。

技術領域

本說明書涉及數據處理技術領域，尤其涉及一種數據統計方法及裝置。

背景技術

計費系統階梯計費能力的實現需要在收費時進行累量，即累計數據量，然后在計費時獲取歷史累計量，看落在哪個階梯，然后根據相應的階梯費率進行計費。由于計費和收費的鏈路穩定性要求差異，計收費平臺能力升級后，將計費和收費系統一分為二，即為分布式計/收費系統。

針對分布式計/收費系統，傳統的并發處理方案中，需要先加鎖來控制并發，然后跟進累計服務量進行計費，再生成賬單，待賬單提交成功后再釋放鎖。顯然，在整個過程中，加鎖時間很長，所有并發業務必須等待鎖釋放后才能繼續處理，從而導致系統的吞吐量很低。

發明內容

本說明書一個或多個實施例的目的是提供一種數據統計方法及裝置，用以實現在分布式系統中統計數據時能夠同時保障系統的吞吐量及并發數據結果的準確性。

為解決上述技術問題，本說明書一個或多個實施例是這樣實現的：

一方面，本說明書一個或多個實施例提供一種數據統計方法，應用于分布式系統，包括：

獲取當前統計周期內的目標數據的第一數據累計量；及，根據所述第一數據累計量，執行計算所述當前統計周期內的第一數據消費量的步驟；

在執行計算所述第一數據消費量的過程中，若并發產生了所述目標數據，則將并發產生的所述目標數據的數據量累加至所述第一數據累計量中，得到第二數據累計量；

根據所述第二數據累計量確定所述當前統計周期內的實際數據消費量；

根據所述實際數據消費量生成所述當前統計周期的數據統計結果。

在一個實施例中，所述獲取當前統計周期內的目標數據的第一數據累計量之后，還包括：

根據預設的多個數據量范圍，確定所述第一數據累計量所在的第一數據量范圍；

根據預設的數據量范圍與數據消費量計算方式之間的對應關系，確定所述第一數據量范圍對應的第一數據消費量計算方式；

相應的，所述計算所述當前統計周期內的第一數據消費量，包括：

按照所述第一數據消費量計算方式，計算所述當前統計周期內的第一數據消費量。

在一個實施例中，所述根據所述第二數據累計量確定所述當前統計周期內的實際數據消費量，包括：

判斷所述第二數據累計量是否位于所述第一數據量范圍；

若是，則確定所述當前統計周期內的實際數據消費量為所述第一數據消費量；

若否，則根據所述第二數據累計量重新計算所述當前統計周期內的第二數據消費量，并確定所述第二數據消費量為所述實際數據消費量。

在一個實施例中，所述根據所述第二數據累計量重新計算所述當前統計周期內的第二數據消費量，包括：

根據所述預設的多個數據量范圍，確定所述第二數據累計量所在的第二數據量范圍；