[發明專利]處理延時任務的方法、裝置、計算機設備和存儲介質

在審

• 申請號: 201911025473.6
• 申請日: 2019-10-25
• 公開（公告）號: CN111026524A
• 公開（公告）日: 2020-04-17
• 發明（設計）人: 宋超;艾國信
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 韓月玲

1.一種處理延時任務的方法，其特征在于，所述方法包括：

獲取延時任務和對應的執行時刻；

將所述延時任務和對應的執行時刻寫入hive數據庫；

當時間運行至預設時刻時，根據各個所述延時任務的執行時刻，從所述hive數據庫獲取與所述預設時刻匹配的延時任務，作為目標延時任務；

按照對各個所述目標延時任務的執行時刻，將各個所述目標延時任務投遞至時間輪對應的槽位；

在所述時間輪的槽位的對應時刻執行所述槽位對應的所述目標延時任務。

2.根據權利要求1所述的方法，其特征在于，所述獲取延時任務和對應的執行時刻，包括：

獲取各個所述延時任務，所述延時任務攜帶延時時長和觸發時刻；

根據各個所述延時任務的所述延時時長和所述觸發時刻計算對應的所述延時任務的執行時刻。

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

根據業務需求計算所述時間輪的時間周期和槽位數量。

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

所述根據各個所述延時任務的執行時刻，從所述hive數據庫獲取與所述預設時刻匹配的延時任務，作為目標延時任務，包括：從所述hive數據庫中獲取與所述預設時刻對應的所述時間周期的延時任務作為所述目標延時任務；

所述按照對各個所述目標延時任務的執行時刻，將各個所述目標延時任務投遞至時間輪對應的槽位，包括：根據所述目標延時任務的執行時刻和獲取所述延時任務的時間計算所述目標延時任務的槽位編號，按照各個所述目標延時任務的槽位編號投遞各個所述目標延時任務。

5.一種延時任務的處理裝置，其特征在于，所述裝置包括：

任務獲取模塊，用于獲取延時任務和對應的執行時刻；

任務寫入模塊，用于將所述延時任務和對應的執行時刻寫入hive數據庫；

任務拉取模塊，用于當時間運行至預設時刻時，根據各個所述延時任務的執行時刻，從所述hive數據庫獲取與所述預設時刻匹配的延時任務，作為目標延時任務；

任務投遞模塊，用于按照對各個所述目標延時任務的執行時刻，將各個所述目標延時任務投遞至時間輪對應的槽位；

任務執行模塊，用于在所述時間輪的槽位的對應時刻執行所述槽位對應的所述目標延時任務。

6.根據權利要求5所述的裝置，其特征在于，所述任務獲取模塊具體用于獲取各個所述延時任務，所述延時任務攜帶延時時長和觸發時刻，根據各個所述延時任務的延時時長和所述觸發時刻計算對應的各個所述延時任務的執行時刻。

7.根據權利要求5或6所述的裝置，其特征在于，所述裝置還包括：

參數配置模塊，用于根據業務需求配置所述時間輪的時間周期和槽位數量。

8.根據權利要求7所述的裝置，其特征在于，所述任務拉取模塊具體用于從所述hive數據庫中獲取與所述預設時刻對應的所述時間周期的延時任務作為所述目標延時任務；

所述任務投遞模塊具體用于根據所述目標延時任務的執行時刻和獲取所述延時任務的時間計算所述目標延時任務的槽位編號，按照各個所述目標延時任務的槽位編號投遞各個所述目標延時任務。

9.一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求1至4中任一項所述方法的步驟。

10.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，所述計算機程序被處理器執行時實現權利要求1至4中任一項所述的方法的步驟。