[發明專利]基于定時任務的數據處理方法、裝置、計算機設備

在審

• 申請號: 202011262157.3
• 申請日: 2020-11-12
• 公開（公告）號: CN112395057A
• 公開（公告）日: 2021-02-23
• 發明（設計）人: 章志良;胥磊
• 申請（專利權）人: 蘇寧云計算有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京市萬慧達律師事務所 11111
• 代理人: 劉艷麗

本申請涉及一種基于定時任務的數據處理方法、裝置、計算機設備和存儲介質。所述方法包括：啟動定時任務，獲取定時任務的業務數據集；在根據定時任務的預設執行順序從業務數據集中獲取數據之前，查詢優先處理隊列中是否存在緩存數據；若是，從優先處理隊列的緩存數據中獲取第一業務數據，并對第一業務數據進行優先處理。采用本方法能夠在不停止定時任務且不破壞數據內容的情況下，靈活、實時地對插入的指定業務數據進行優先處理。

技術領域

本申請涉及數據處理技術領域，特別是涉及一種基于定時任務的數據處理方法、裝置、計算機設備和存儲介質。

背景技術

隨著數據處理技術的發展，出現了通過定時任務進行數據處理的技術，在實際應用中，對于不需要實時處理的數據，往往都采用定時任務進行調度并分批處理。采用定時任務，一方面解耦了數據對上游系統的影響，另一方面通過對定時任務的執行頻率和執行條數的控制,可以有效避免數據峰值對系統性能的沖擊。

定時任務進行數據處理時，往往都是按照一定的順序執行，一旦數據出現積壓，緊急業務的數據無法提前進行處理，影響了緊急業務完成的效率。

傳統技術中，定時任務處理數據時,通常都是按照數據的保存時間來順序處理的,以先進先出的順序進行處理，如果數據出現積壓，不具備優先處理部分數據的功能。對于緊急業務的數據，除非更改其保存時間，但如此一來，破壞了數據內容的真實性，而且即使更改了保存時間也不能馬上處理，只能等到當前定時任務執行完畢后，啟動下一次定時任務后才能執行。

發明內容

基于此，有必要針對上述技術問題，提供一種能夠提高緊急數據處理及時性的基于定時任務的數據處理方法、裝置、計算機設備和存儲介質。

一種基于定時任務的數據處理方法，上述方法包括：

啟動定時任務，獲取定時任務的業務數據集；

在根據定時任務的預設執行順序從業務數據集中獲取數據之前，查詢優先處理隊列中是否存在緩存數據；

若是，從優先處理隊列的緩存數據中獲取第一業務數據，并對第一業務數據進行優先處理。

在一個實施例中，上述方法還包括：

若否，根據定時任務的預設執行順序從業務數據集中獲取第二業務數據，并對第二業務數據進行處理。

在一個實施例中，在對第二業務數據進行處理之后，還包括：

判斷第二業務數據是否是業務數據集中的最后一條數據，若否，返回執行查詢優先處理隊列中是否存在緩存數據的步驟。

在一個實施例中，對第一業務數據進行優先處理之后，還包括：

生成第一業務數據對應的優先執行記錄。

在一個實施例中，對第二業務數據進行處理之前，包括：

判斷第二業務數據是否存在對應的優先執行記錄，若否，執行對第二業務數據進行處理的步驟。

在一個實施例中，對第二業務數據進行處理之前，包括：

判斷第二業務數據是否存在對應的優先執行記錄，若是，返回執行查詢優先處理隊列中是否存在緩存數據的步驟。

在一個實施例中，生成第一業務數據對應的優先執行記錄，包括：

通過鍵值對的形式生成第一業務數據對應的優先執行記錄。

在一個實施例中，通過鍵值對的形式生成第一業務數據對應的優先執行記錄，包括：

以第一業務數據的標識為該鍵值對的主鍵，處理第一業務數據的時間戳為該鍵值對的值，生成第一業務數據對應的優先執行記錄。