[發(fā)明專利]基于定時任務(wù)的數(shù)據(jù)處理方法、裝置、計算機設(shè)備

在審

• 申請?zhí)枺?/td>: 202011262157.3
• 申請日: 2020-11-12
• 公開（公告）號: CN112395057A
• 公開（公告）日: 2021-02-23
• 發(fā)明（設(shè)計）人: 章志良;胥磊
• 申請（專利權(quán)）人: 蘇寧云計算有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京市萬慧達律師事務(wù)所 11111
• 代理人: 劉艷麗

1.一種基于定時任務(wù)的數(shù)據(jù)處理方法，所述方法包括：

啟動定時任務(wù)，獲取所述定時任務(wù)的業(yè)務(wù)數(shù)據(jù)集；

在根據(jù)所述定時任務(wù)的預(yù)設(shè)執(zhí)行順序從所述業(yè)務(wù)數(shù)據(jù)集中獲取數(shù)據(jù)之前，查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)；

若是，從所述優(yōu)先處理隊列的緩存數(shù)據(jù)中獲取第一業(yè)務(wù)數(shù)據(jù)，并對所述第一業(yè)務(wù)數(shù)據(jù)進行優(yōu)先處理；

若否，根據(jù)所述定時任務(wù)的預(yù)設(shè)執(zhí)行順序從所述業(yè)務(wù)數(shù)據(jù)集中獲取第二業(yè)務(wù)數(shù)據(jù)，并對所述第二業(yè)務(wù)數(shù)據(jù)進行處理；

在所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理之后，還包括：

判斷所述第二業(yè)務(wù)數(shù)據(jù)是否是所述業(yè)務(wù)數(shù)據(jù)集中的最后一條數(shù)據(jù)，若否，返回執(zhí)行查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)的步驟；

其中，所述對所述第一業(yè)務(wù)數(shù)據(jù)進行優(yōu)先處理之后，還包括：

生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

其中，所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理之前，還包括：

判斷所述第二業(yè)務(wù)數(shù)據(jù)是否存在對應(yīng)的優(yōu)先執(zhí)行記錄，若否，執(zhí)行所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理的步驟；或，

若是，返回執(zhí)行所述查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)的步驟；

其中，所述生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄，包括：

通過鍵值對的形式生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

所述通過鍵值對的形式生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄，包括：

以所述第一業(yè)務(wù)數(shù)據(jù)的標(biāo)識為所述鍵值對的主鍵，處理所述第一業(yè)務(wù)數(shù)據(jù)的時間戳為所述鍵值對的值，生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

其中，所述判斷所述第二業(yè)務(wù)數(shù)據(jù)是否存在對應(yīng)的優(yōu)先執(zhí)行記錄，包括：

根據(jù)所述第二業(yè)務(wù)數(shù)據(jù)的標(biāo)識判斷是否存在以第二業(yè)務(wù)數(shù)據(jù)的標(biāo)識作為主鍵的優(yōu)先執(zhí)行記錄；

在接收到業(yè)務(wù)數(shù)據(jù)的篩選指令時，根據(jù)所述篩選指令從待處理的業(yè)務(wù)數(shù)據(jù)中篩選出所述第一業(yè)務(wù)數(shù)據(jù)；

將所述第一業(yè)務(wù)數(shù)據(jù)存入所述優(yōu)先處理隊列。

2.一種基于定時任務(wù)的數(shù)據(jù)處理裝置，其特征在于，所述裝置包括：

任務(wù)獲取模塊，用于啟動定時任務(wù)，獲取所述定時任務(wù)的業(yè)務(wù)數(shù)據(jù)集；

緩存查詢模塊，用于在根據(jù)所述定時任務(wù)的預(yù)設(shè)執(zhí)行順序從所述業(yè)務(wù)數(shù)據(jù)集中獲取數(shù)據(jù)之前，查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)；

數(shù)據(jù)處理模塊，用于若是，從所述優(yōu)先處理隊列的緩存數(shù)據(jù)中獲取第一業(yè)務(wù)數(shù)據(jù)，并對所述第一業(yè)務(wù)數(shù)據(jù)進行優(yōu)先處理；

若否，根據(jù)所述定時任務(wù)的預(yù)設(shè)執(zhí)行順序從所述業(yè)務(wù)數(shù)據(jù)集中獲取第二業(yè)務(wù)數(shù)據(jù)，并對所述第二業(yè)務(wù)數(shù)據(jù)進行處理；

在所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理之后，還包括：

判斷所述第二業(yè)務(wù)數(shù)據(jù)是否是所述業(yè)務(wù)數(shù)據(jù)集中的最后一條數(shù)據(jù)，若否，返回執(zhí)行查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)的步驟；

其中，所述對所述第一業(yè)務(wù)數(shù)據(jù)進行優(yōu)先處理之后，還包括：

生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

其中，所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理之前，還包括：

判斷所述第二業(yè)務(wù)數(shù)據(jù)是否存在對應(yīng)的優(yōu)先執(zhí)行記錄，若否，執(zhí)行所述對所述第二業(yè)務(wù)數(shù)據(jù)進行處理的步驟；或，

若是，返回執(zhí)行所述查詢優(yōu)先處理隊列中是否存在緩存數(shù)據(jù)的步驟；

其中，所述生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄，包括：

通過鍵值對的形式生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

所述通過鍵值對的形式生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄，包括：

以所述第一業(yè)務(wù)數(shù)據(jù)的標(biāo)識為所述鍵值對的主鍵，處理所述第一業(yè)務(wù)數(shù)據(jù)的時間戳為所述鍵值對的值，生成所述第一業(yè)務(wù)數(shù)據(jù)對應(yīng)的優(yōu)先執(zhí)行記錄；

指令篩選模塊，用于在接收到業(yè)務(wù)數(shù)據(jù)的篩選指令時，根據(jù)所述篩選指令從待處理的業(yè)務(wù)數(shù)據(jù)中篩選出所述第一業(yè)務(wù)數(shù)據(jù)；

將所述第一業(yè)務(wù)數(shù)據(jù)存入所述優(yōu)先處理隊列。

3.一種計算機設(shè)備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執(zhí)行所述計算機程序時實現(xiàn)權(quán)利要求1所述方法的步驟。

4.一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，其特征在于，所述計算機程序被處理器執(zhí)行時實現(xiàn)權(quán)利要求1所述的方法的步驟。