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

在審

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

本申請涉及一種處理延時任務的方法、裝置、計算機設備和存儲介質。所述方法包括：獲取延時任務和對應的執行時刻；將延時任務和對應的執行時刻寫入hive數據庫；當時間運行至預設時刻時，根據各個延時任務的執行時刻，從hive數據庫獲取與預設時刻匹配的延時任務，作為目標延時任務；按照對各個目標延時任務的執行時刻，將各個目標延時任務投遞至時間輪對應的槽位；在時間輪的槽位的對應時刻執行槽位對應的所述目標延時任務。由于hive具有查詢速度快、數據存儲量大的特點，故采用hive存儲延時任務可以存儲大量的延時任務，定時查詢hive中的延時任務時，可以快速拉取hive中的延時任務，通過時間輪定時執行拉取到的任務，提高延時任務的執行準確度。

技術領域

本申請涉及計算機技術領域，尤其涉及一種處理延時任務的方法、裝置、計算機設備和存儲介質。

背景技術

隨著開放平臺的某些業務場景需要對一些業務進行延遲執行，比如下單后半個小時檢查是否付款，活動邀請碼發出去3天后檢查是否使用等等，延遲執行時間不固定，隨著業務量以及用戶的增加，延遲任務數量也會很大。目前處理的方式是每個任務都添加定時掃描功能，檢測是否需要執行，針對延遲任務的具體執行時間，如果檢測間隔時間短，對IO性能影響大，如果檢測間隔時間長，又不能按照延時任務的實際執行時間執行任務，隨著任務數量不斷增多，海量延遲任務的準確執行成為了急需解決的問題。

發明內容

為了解決上述技術問題，本申請提供了一種處理延時任務的方法、裝置、計算機設備和存儲介質。

第一方面，本申請提供了一種處理延時任務的方法，包括：

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

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

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

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

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

第二方面，本申請提供了一種處理延時任務的裝置，包括：

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

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

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

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

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

一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現以下步驟：

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

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

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

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

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

一種計算機可讀存儲介質，其上存儲有計算機程序，所述計算機程序被處理器執行時實現以下步驟：