[發明專利]實時計算中數據超時的處理方法及裝置

在審

• 申請號: 202110557272.1
• 申請日: 2021-05-21
• 公開（公告）號: CN113204387A
• 公開（公告）日: 2021-08-03
• 發明（設計）人: 鄒學;黃飚
• 申請（專利權）人: 珠海金山網絡游戲科技有限公司
• 主分類號: G06F9/445
• 分類號: G06F9/445;G06F16/22;G06F16/2455
• 代理公司: 北京智信禾專利代理有限公司 11637
• 代理人: 劉曉楠

1.一種實時計算中數據超時的處理方法，其特征在于，包括：

獲取待處理數據，其中，所述待處理數據攜帶生成時間和到達時間；

確定所述生成時間所屬的目標時間窗；

若所述到達時間超出所述目標時間窗，則從緩存中獲取生成時間在所述目標時間窗內的緩存數據；

基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果。

2.如權利要求1所述的實時計算中數據超時的處理方法，其特征在于，所述緩存數據包括生成時間在所述目標時間窗內的歷史數據的處理結果；

基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果，包括：

在所述待處理數據的到達時間所屬的時間窗內，對所述待處理數據進行處理，確定所述待處理數據的處理結果；

識別所述待處理數據和所述歷史數據攜帶的業務標識，確定所述業務標識指示的業務邏輯；

基于所述業務邏輯，對所述待處理數據的處理結果和所述歷史數據的處理結果進行處理，得到所述目標時間窗內數據的處理結果。

3.如權利要求1所述的實時計算中數據超時的處理方法，其特征在于，所述緩存數據包括生成時間在所述目標時間窗內的歷史數據；

基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果，包括：

在所述待處理數據的到達時間所屬的時間窗內，對所述待處理數據和所述歷史數據進行處理，得到所述目標時間窗內數據的處理結果。

4.如權利要求1所述的實時計算中數據超時的處理方法，其特征在于，確定所述生成時間所屬的目標時間窗之后，還包括：

若所述到達時間在所述目標時間窗內，則對所述待處理數據進行處理。

5.如權利要求4所述的實時計算中數據超時的處理方法，其特征在于，對所述待處理數據進行處理，包括：

在所述目標時間窗的結束時刻，對所述待處理數據進行處理。

6.如權利要求1所述的實時計算中數據超時的處理方法，其特征在于，獲取待處理數據之后，還包括：

將所述待處理數據存儲至緩存中；

或者，

基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果之后，還包括：

將所述待處理數據和/或所述目標時間窗內數據的處理結果存儲至緩存中。

7.如權利要求1所述的實時計算中數據超時的處理方法，其特征在于，所述方法還包括：

若從緩存中未獲取到生成時間在所述目標時間窗內的緩存數據，則在所述待處理數據的到達時間所屬的時間窗內，對所述待處理數據進行處理。

8.一種實時計算中數據超時的處理裝置，其特征在于，包括：

第一獲取模塊，被配置為獲取待處理數據，其中，所述待處理數據攜帶生成時間和到達時間；

第一確定模塊，被配置為確定所述生成時間所屬的目標時間窗；

第二獲取模塊，被配置為若所述到達時間超出所述目標時間窗，則從緩存中獲取生成時間在所述目標時間窗內的緩存數據；

第二確定模塊，被配置為基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果。

9.一種計算設備，其特征在于，包括：

存儲器和處理器；

所述存儲器用于存儲計算機可執行指令，所述處理器用于執行所述計算機可執行指令，以實現下述方法：

獲取待處理數據，其中，所述待處理數據攜帶生成時間和到達時間；

確定所述生成時間所屬的目標時間窗；

若所述到達時間超出所述目標時間窗，則從緩存中獲取生成時間在所述目標時間窗內的緩存數據；

基于所述緩存數據和所述待處理數據，確定所述目標時間窗內數據的處理結果。

10.一種計算機可讀存儲介質，其存儲有計算機指令，該指令被處理器執行時實現權利要求1至7任意一項所述實時計算中數據超時的處理方法的步驟。