[發(fā)明專利]一種批處理任務(wù)調(diào)度方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201611219901.5
• 申請(qǐng)日: 2016-12-26
• 公開（公告）號(hào): CN106775985A
• 公開（公告）日: 2017-05-31
• 發(fā)明（設(shè)計(jì)）人: 徐冬冬;岳瑋;陳清江;孫宇晨;劉天寶
• 申請(qǐng)（專利權(quán)）人: 中國(guó)建設(shè)銀行股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司11227
• 代理人: 王寶筠

技術(shù)領(lǐng)域

本申請(qǐng)涉及軟件領(lǐng)域，特別涉及一種批處理任務(wù)調(diào)度方法及裝置。

背景技術(shù)

在現(xiàn)代企業(yè)應(yīng)用當(dāng)中，面對(duì)復(fù)雜的業(yè)務(wù)以及海量的數(shù)據(jù)，除了通過龐雜的人機(jī)交互界面進(jìn)行各種處理外，還有一種處理方式，即批處理，批處理不需要人工干預(yù)，只需要定期讀入大批量數(shù)據(jù)，然后完成相應(yīng)業(yè)務(wù)處理并進(jìn)行歸檔。

批處理方式作為現(xiàn)代企業(yè)應(yīng)用當(dāng)中不可或缺的數(shù)據(jù)處理方式，如何高效的執(zhí)行批處理任務(wù)成為問題。

發(fā)明內(nèi)容

為解決上述技術(shù)問題，本申請(qǐng)實(shí)施例提供一種批處理任務(wù)調(diào)度方法及裝置，以達(dá)到提高調(diào)度執(zhí)行批處理任務(wù)的效率的目的，技術(shù)方案如下：

一種批處理任務(wù)調(diào)度方法，應(yīng)用于任務(wù)調(diào)度框架Quartz服務(wù)器，所述方法包括：

掃描登記記錄表，將所述登記記錄表中的每條定義分別生成任務(wù)調(diào)度標(biāo)識(shí)，所述登記記錄表中的每條定義包括批處理任務(wù)邏輯的索引、執(zhí)行任務(wù)類型、任務(wù)執(zhí)行周期或頻率；

將生成的各個(gè)任務(wù)調(diào)度標(biāo)識(shí)注冊(cè)到批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中，以建立各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)與所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中批處理任務(wù)邏輯的對(duì)應(yīng)關(guān)系；

按照各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的任務(wù)執(zhí)行頻率或周期，調(diào)度執(zhí)行所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯。

優(yōu)選的，在所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯為周期性的批處理任務(wù)邏輯的情況下，按照各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的任務(wù)執(zhí)行頻率或周期，調(diào)度執(zhí)行所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯之后，還包括：

生成所述周期性的批處理任務(wù)邏輯的下一次執(zhí)行時(shí)間，并針對(duì)所述周期性的批處理任務(wù)邏輯生成一條單獨(dú)的任務(wù)實(shí)例，并標(biāo)注所述單獨(dú)的任務(wù)實(shí)例的執(zhí)行時(shí)間、計(jì)劃開始執(zhí)行時(shí)間、實(shí)際開始執(zhí)行時(shí)間和實(shí)際結(jié)束執(zhí)行時(shí)間；

在所述登記記錄表中設(shè)置標(biāo)志位，用于存儲(chǔ)所述單獨(dú)的任務(wù)實(shí)例的執(zhí)行狀態(tài)。

優(yōu)選的，在所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯為遇到節(jié)假日需要特殊處理的任務(wù)、每N(N>1)日/周執(zhí)行的任務(wù)、每個(gè)執(zhí)行日可能執(zhí)行多次的任務(wù)或月末執(zhí)行的任務(wù)的情況下，調(diào)度執(zhí)行所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯，包括：

在每天的預(yù)設(shè)時(shí)刻判斷當(dāng)日是否是執(zhí)行日；

若當(dāng)日是執(zhí)行日，則執(zhí)行父任務(wù)，以判斷是否應(yīng)該預(yù)約子任務(wù)，所述子任務(wù)為所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯中的某一個(gè)批處理任務(wù)邏輯；

若應(yīng)該預(yù)約子任務(wù)，則預(yù)約所述子任務(wù)；

若不應(yīng)該預(yù)約子任務(wù)，則不預(yù)約所述子任務(wù)。

優(yōu)選的，判斷是否應(yīng)該預(yù)約子任務(wù)，包括：

判斷預(yù)約日期是否為節(jié)假日，得到第一判斷結(jié)果；

判斷所述預(yù)約日期是否為執(zhí)行日，得到第二判斷結(jié)果；

根據(jù)所述第一判斷結(jié)果和所述第二判斷結(jié)果確定是否預(yù)約所述子任務(wù)。

一種批處理任務(wù)調(diào)度裝置，應(yīng)用于任務(wù)調(diào)度框架Quartz服務(wù)器，所述裝置包括：

生成模塊，用于掃描登記記錄表，將所述登記記錄表中的每條定義分別生成任務(wù)調(diào)度標(biāo)識(shí)，所述登記記錄表中的每條定義包括批處理任務(wù)邏輯的索引、執(zhí)行任務(wù)類型、任務(wù)執(zhí)行周期或頻率；

注冊(cè)模塊，用于將生成的各個(gè)任務(wù)調(diào)度標(biāo)識(shí)注冊(cè)到批處理框架SpringBatch的任務(wù)倉(cāng)庫(kù)中，以建立各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)與所述批處理框架SpringBatch的任務(wù)倉(cāng)庫(kù)中批處理任務(wù)邏輯的對(duì)應(yīng)關(guān)系；

調(diào)度執(zhí)行模塊，用于按照各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的任務(wù)執(zhí)行頻率或周期，調(diào)度執(zhí)行所述批處理框架Spring Batch的任務(wù)倉(cāng)庫(kù)中各個(gè)所述任務(wù)調(diào)度標(biāo)識(shí)對(duì)應(yīng)的批處理任務(wù)邏輯。

優(yōu)選的，所述調(diào)度執(zhí)行模塊包括：

生成單元，用于生成所述周期性的批處理任務(wù)邏輯的下一次執(zhí)行時(shí)間，并針對(duì)所述周期性的批處理任務(wù)邏輯生成一條單獨(dú)的任務(wù)實(shí)例，并標(biāo)注所述單獨(dú)的任務(wù)實(shí)例的執(zhí)行時(shí)間、計(jì)劃開始執(zhí)行時(shí)間、實(shí)際開始執(zhí)行時(shí)間和實(shí)際結(jié)束執(zhí)行時(shí)間；

設(shè)置單元，用于在所述登記記錄表中設(shè)置標(biāo)志位，用于存儲(chǔ)所述單獨(dú)的任務(wù)實(shí)例的執(zhí)行狀態(tài)。

優(yōu)選的，所述調(diào)度執(zhí)行模塊包括：

判斷單元，用于在每天的預(yù)設(shè)時(shí)刻判斷當(dāng)日是否是執(zhí)行日，若當(dāng)日是執(zhí)行日，則觸發(fā)執(zhí)行單元；