[發明專利]一種實時數據的處理方法及裝置

有效

• 申請號: 201910515532.1
• 申請日: 2019-06-14
• 公開（公告）號: CN110297602B
• 公開（公告）日: 2023-03-07
• 發明（設計）人: 胡文;丁浩
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F3/06
• 分類號: G06F3/06
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙) 11413
• 代理人: 丁蕓;項京

1.一種實時數據的處理方法，其特征在于，所述實時數據被按照預定的處理周期進行存儲，每一處理周期對應一個用于存儲實時數據的數據分區；所述方法包括：

當收集到每一條實時數據時，確定該實時數據的生成時間；

判斷所述生成時間是否位于當前處理周期對應的允許處理范圍內；其中，任一處理周期對應的允許處理范圍為(X₁，X₂]或[X₁，X₂)，X₁為該處理周期的起始點之前預設時長的時間點，X₂為該處理周期的結束點之前預設時長的時間點，該處理周期的下一個處理周期對應的允許處理范圍的X₁的值等于該處理周期對應的允許處理范圍的X₂的值；

當判斷結果為是時，將該實時數據存儲到第一緩沖隊列中；

當判斷結果為否時，判斷所述生成時間是否不小于當前處理周期對應的允許處理范圍的X₂；如果是，將該實時數據存儲到第二緩沖隊列中；

當檢測到當前處理周期結束時，將所述第一緩沖隊列中的實時數據，均存入當前處理周期對應的數據分區中，清空所述第一緩沖隊列，并將所述第二緩沖隊列中的實時數據復制至所述第一緩沖隊列中，進入下一個處理周期。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

當所述判斷結果為否且所述生成時間不大于當前處理周期對應的允許處理范圍的X₁時，將該實時數據丟棄。

3.根據權利要求1所述的方法，其特征在于，所述當收集到每一條實時數據時，確定該實時數據的生成時間，包括：

當收集到每一條實時數據時，確定該實時數據的日志生成時間，將所確定的日志生成時間作為該實時數據的生成時間。

4.根據權利要求1-3任一項所述的方法，其特征在于，所述實時數據，包括：視頻點播服務類型的實時數據。

5.一種實時數據的處理裝置，其特征在于，所述實時數據被按照預定的處理周期進行存儲，每一處理周期對應一個用于存儲實時數據的數據分區；所述裝置包括：

確定模塊，用于當收集到每一條實時數據時，確定該實時數據的生成時間；

第一判斷模塊，用于判斷所述生成時間是否位于當前處理周期對應的允許處理范圍內；

第一存儲模塊，用于在所述判斷模塊的判斷結果為是時，將該實時數據存儲到第一緩沖隊列中；其中，任一處理周期對應的允許處理范圍為(X₁，X₂]或[X₁，X₂)，X₁為該處理周期的起始點之前預設時長的時間點，X₂為該處理周期的結束點之前預設時長的時間點，該處理周期的下一個處理周期對應的允許處理范圍的X₁的值等于該處理周期對應的允許處理范圍的X₂的值；

第二判斷模塊，用于在所述第一判斷模塊的判斷結果為否時，判斷所述生成時間是否不小于當前處理周期對應的允許處理范圍的X₂；

第二存儲模塊，用于在所述第二判斷模塊的判斷結果為是時，將該實時數據存儲到第二緩沖隊列中；

第三存儲模塊，用于當檢測到當前處理周期結束時，將所述第一緩沖隊列中的實時數據，均存入當前處理周期對應的數據分區中，清空所述第一緩沖隊列，并將所述第二緩沖隊列中的實時數據復制至所述第一緩沖隊列中，進入下一個處理周期。

6.根據權利要求5所述的裝置，其特征在于，所述裝置還包括：丟棄模塊；

所述丟棄模塊，用于在所述判斷結果為否且所述生成時間不大于當前處理周期對應的允許處理范圍的X₁時，將該實時數據丟棄。

7.根據權利要求5所述的裝置，其特征在于，所述確定模塊，具體用于：

當收集到每一條實時數據時，確定該實時數據的日志生成時間，將所確定的日志生成時間作為該實時數據的生成時間。