[發(fā)明專利]數(shù)據(jù)的計量統(tǒng)計方法、裝置、電子設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110332755.1
• 申請日: 2021-03-29
• 公開（公告）號: CN113010852A
• 公開（公告）日: 2021-06-22
• 發(fā)明（設(shè)計）人: 劉彬
• 申請（專利權(quán)）人: 北京金山云網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號: G06F17/18
• 分類號: G06F17/18
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 魯麗美

1.一種數(shù)據(jù)的計量統(tǒng)計方法，其特征在于，包括：

獲取第一服務(wù)的通知信息；所述通知信息至少用于表示所述第一服務(wù)當(dāng)前完成對預(yù)定數(shù)量單位的待處理數(shù)據(jù)的處理；

根據(jù)所述通知信息，觸發(fā)所述第一服務(wù)內(nèi)部維護(hù)的計數(shù)器對所述預(yù)定數(shù)量單位的待處理數(shù)據(jù)進(jìn)行計數(shù)處理，得到相匹配的計數(shù)結(jié)果；

在滿足時間條件情況下，利用中間存儲媒介將所述計數(shù)器的計數(shù)結(jié)果轉(zhuǎn)移存儲至目標(biāo)位置。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述獲取第一服務(wù)的通知信息，包括：

利用所述第一服務(wù)內(nèi)部啟動的輔助線程接收所述第一服務(wù)的通知信息；

所述根據(jù)所述通知信息，觸發(fā)所述第一服務(wù)內(nèi)部的計數(shù)器對所述預(yù)定數(shù)量單位的待處理數(shù)據(jù)進(jìn)行計數(shù)處理，包括：

所述輔助線程觸發(fā)所述計數(shù)器根據(jù)所述通知信息中包括的分區(qū)信息，在目標(biāo)分區(qū)統(tǒng)計維度對所述預(yù)定數(shù)量單位的待處理數(shù)據(jù)進(jìn)行計數(shù)處理；

其中，所述第一服務(wù)的待處理數(shù)據(jù)屬于多個數(shù)據(jù)分區(qū)中的相應(yīng)分區(qū)；所述分區(qū)信息用于指示所述預(yù)定數(shù)量單位的待處理數(shù)據(jù)所屬的目標(biāo)數(shù)據(jù)分區(qū)；所述目標(biāo)分區(qū)統(tǒng)計維度為與所述目標(biāo)數(shù)據(jù)分區(qū)對應(yīng)的統(tǒng)計維度。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述在目標(biāo)分區(qū)統(tǒng)計維度對所述預(yù)定數(shù)量單位的待處理數(shù)據(jù)進(jìn)行計數(shù)處理，包括：

將計數(shù)器在所述目標(biāo)分區(qū)統(tǒng)計維度對應(yīng)的至少一個計數(shù)周期維度的計數(shù)結(jié)果，增加所述預(yù)定數(shù)量單位。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述計數(shù)器為原子計數(shù)器；

所述原子計數(shù)器存儲有所述多個數(shù)據(jù)分區(qū)的分區(qū)信息集合，集合中的不同分區(qū)信息分別對應(yīng)不同的分區(qū)統(tǒng)計維度；

所述原子計數(shù)器基于鎖機(jī)制，避免不同通知信息分別對應(yīng)的不同計數(shù)任務(wù)之間的計數(shù)沖突。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述在滿足時間條件情況下，利用中間存儲媒介將所述計數(shù)器的計數(shù)結(jié)果轉(zhuǎn)移存儲至目標(biāo)位置，包括：

在滿足第一時間條件情況下，將所述計數(shù)器的計數(shù)結(jié)果寫入第一服務(wù)的本地文件；

在滿足第二時間條件情況下，將所述本地文件存儲至預(yù)定存儲位置；

對所述預(yù)定存儲位置的至少一個本地文件的計數(shù)數(shù)據(jù)進(jìn)行聚合處理，得到第一聚合結(jié)果；將所述第一聚合結(jié)果寫入數(shù)據(jù)庫并存儲；

其中，不同本地文件分別為相同第一服務(wù)或不同第一服務(wù)的本地文件。

6.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述在滿足時間條件情況下，利用中間存儲媒介將所述計數(shù)器的計數(shù)結(jié)果轉(zhuǎn)移存儲至目標(biāo)位置，包括：

在滿足第三時間條件情況下，將所述計數(shù)器的計數(shù)結(jié)果寫入預(yù)定消息隊列組件的第一消息隊列；

從所述第一消息隊列獲取至少一個第一服務(wù)的計數(shù)器計數(shù)結(jié)果；

對所述至少一個第一服務(wù)的計數(shù)器計數(shù)結(jié)果進(jìn)行聚合處理，得到第二聚合結(jié)果；將所述第二聚合結(jié)果寫入數(shù)據(jù)庫并存儲。

7.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述第一服務(wù)通過至少一個第二消息隊列獲取第二服務(wù)推送的待處理數(shù)據(jù)；

每一第二消息隊列為所述第一服務(wù)對應(yīng)的一個數(shù)據(jù)分區(qū)。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，所述第二服務(wù)維護(hù)有多維內(nèi)存數(shù)組；所述多維內(nèi)存數(shù)組的不同維度分別對應(yīng)所述第一服務(wù)的不同數(shù)據(jù)分區(qū)；

所述第二服務(wù)每產(chǎn)生一待處理數(shù)據(jù)，則將產(chǎn)生的待處理數(shù)據(jù)的預(yù)定屬性信息記錄至所述多維內(nèi)存數(shù)組中與產(chǎn)生的待處理數(shù)據(jù)的分區(qū)信息相匹配的維度空間；

在所述多維內(nèi)存數(shù)組的相應(yīng)維度空間記錄的預(yù)定屬性信息滿足批量處理條件時，將所述相應(yīng)維度空間記錄的信息所對應(yīng)的多條待處理數(shù)據(jù)批量推送至相匹配的第二消息隊列進(jìn)行發(fā)送。