[發(fā)明專利]批量作業(yè)執(zhí)行方法、裝置、設(shè)備、介質(zhì)和產(chǎn)品

在審

• 申請(qǐng)?zhí)枺?/td>: 202111574616.6
• 申請(qǐng)日: 2021-12-21
• 公開(kāi)（公告）號(hào): CN114240632A
• 公開(kāi)（公告）日: 2022-03-25
• 發(fā)明（設(shè)計(jì)）人: 黎錫軍;李丹;邱韜奮;徐策
• 申請(qǐng)（專利權(quán)）人: 中國(guó)建設(shè)銀行股份有限公司
• 主分類號(hào): G06Q40/02
• 分類號(hào): G06Q40/02;G06Q10/06
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 駱文欣

本發(fā)明公開(kāi)了一種批量作業(yè)執(zhí)行方法、裝置、設(shè)備、介質(zhì)和產(chǎn)品，涉及大數(shù)據(jù)任務(wù)調(diào)度技術(shù)領(lǐng)域。該方法包括：獲取當(dāng)前批量作業(yè)節(jié)點(diǎn)中每個(gè)待處理作業(yè)的當(dāng)前屬性信息；根據(jù)當(dāng)前屬性信息中的業(yè)務(wù)數(shù)據(jù)量確定對(duì)應(yīng)待處理作業(yè)的執(zhí)行時(shí)間；根據(jù)執(zhí)行時(shí)間實(shí)時(shí)調(diào)整對(duì)應(yīng)待處理作業(yè)在當(dāng)前批量作業(yè)節(jié)點(diǎn)中的執(zhí)行順序；按照?qǐng)?zhí)行順序執(zhí)行當(dāng)前批量作業(yè)節(jié)點(diǎn)中的所有待處理作業(yè)。本發(fā)明實(shí)施例通過(guò)根據(jù)待處理作業(yè)的業(yè)務(wù)數(shù)據(jù)量確定對(duì)應(yīng)的執(zhí)行時(shí)間，并根據(jù)執(zhí)行時(shí)間動(dòng)態(tài)地實(shí)時(shí)調(diào)整對(duì)應(yīng)待處理作業(yè)在當(dāng)前批量作業(yè)節(jié)點(diǎn)中的執(zhí)行順序，適應(yīng)了當(dāng)前批量作業(yè)節(jié)點(diǎn)所對(duì)應(yīng)業(yè)務(wù)的變化，達(dá)到了最優(yōu)的批處理效率。

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

本發(fā)明實(shí)施例涉及大數(shù)據(jù)任務(wù)調(diào)度技術(shù)領(lǐng)域，尤其涉及一種批量作業(yè)執(zhí)行方法、裝置、設(shè)備、介質(zhì)和產(chǎn)品。

背景技術(shù)

批處理是銀行系統(tǒng)中不可缺少的一環(huán)，它根據(jù)不同的業(yè)務(wù)需求對(duì)已有的數(shù)據(jù)進(jìn)行加工，實(shí)現(xiàn)了系統(tǒng)自身或者系統(tǒng)與系統(tǒng)間的數(shù)據(jù)交互保障系統(tǒng)的正常運(yùn)作。系統(tǒng)的日常批量由多個(gè)批處理作業(yè)組成，不同的作業(yè)處理時(shí)間不同，作業(yè)和作業(yè)之間存在著依賴關(guān)系。隨著銀行業(yè)務(wù)的多樣性和復(fù)雜性的增加，批處理作業(yè)越來(lái)越多，整個(gè)批處理的流程越來(lái)越復(fù)雜，整個(gè)批量耗時(shí)也變得越來(lái)越長(zhǎng)。在資源一定的情況下，為了保證批處理作業(yè)按時(shí)完成保障系統(tǒng)可正常營(yíng)業(yè)，開(kāi)發(fā)人員根據(jù)批處理作業(yè)的依賴關(guān)系和處理時(shí)間編排執(zhí)行流程，減少執(zhí)行時(shí)間。然而互聯(lián)網(wǎng)時(shí)代，銀行業(yè)務(wù)瞬息萬(wàn)變，同一個(gè)業(yè)務(wù)的業(yè)務(wù)量在短時(shí)間內(nèi)發(fā)生較大的變化，數(shù)據(jù)量也發(fā)生增長(zhǎng)，與之相關(guān)的批處理作業(yè)耗時(shí)也隨之增加，如果再按照原來(lái)編排的流程運(yùn)行就可能達(dá)不到最優(yōu)。因此能夠根據(jù)批處理作業(yè)執(zhí)行情況調(diào)整執(zhí)行流程，在一定的資源條件下，執(zhí)行時(shí)間最短，是本發(fā)明需要解決的問(wèn)題。

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

有鑒于此，本發(fā)明提供一種批量作業(yè)執(zhí)行方法、裝置、設(shè)備、介質(zhì)和產(chǎn)品，達(dá)到了最優(yōu)的批處理效率。

第一方面，本發(fā)明實(shí)施例提供了一種批量作業(yè)執(zhí)行方法，包括：

獲取當(dāng)前批量作業(yè)節(jié)點(diǎn)中每個(gè)待處理作業(yè)的當(dāng)前屬性信息；其中，每個(gè)批量作業(yè)節(jié)點(diǎn)中至少包括兩個(gè)待處理作業(yè)，并且，每個(gè)批量作業(yè)節(jié)點(diǎn)之間的依賴關(guān)系為上下層關(guān)系；每個(gè)批量作業(yè)節(jié)點(diǎn)之間的執(zhí)行順序?yàn)榇袌?zhí)行，以及每個(gè)批量作業(yè)節(jié)點(diǎn)中每個(gè)待處理作業(yè)的執(zhí)行順序?yàn)椴⑿袌?zhí)行；

根據(jù)所述當(dāng)前屬性信息中的業(yè)務(wù)數(shù)據(jù)量確定對(duì)應(yīng)待處理作業(yè)的執(zhí)行時(shí)間；

根據(jù)所述執(zhí)行時(shí)間實(shí)時(shí)調(diào)整對(duì)應(yīng)待處理作業(yè)在所述當(dāng)前批量作業(yè)節(jié)點(diǎn)中的執(zhí)行順序；

按照所述執(zhí)行順序執(zhí)行所述當(dāng)前批量作業(yè)節(jié)點(diǎn)中的所有待處理作業(yè)。

第二方面，本發(fā)明實(shí)施例還提供了一種批量作業(yè)執(zhí)行裝置，包括：

獲取模塊，用于獲取當(dāng)前批量作業(yè)節(jié)點(diǎn)中每個(gè)待處理作業(yè)的當(dāng)前屬性信息；其中，每個(gè)批量作業(yè)節(jié)點(diǎn)中至少包括兩個(gè)待處理作業(yè)，并且，每個(gè)批量作業(yè)節(jié)點(diǎn)之間的依賴關(guān)系為上下層關(guān)系；每個(gè)批量作業(yè)節(jié)點(diǎn)之間的執(zhí)行順序?yàn)榇袌?zhí)行，以及每個(gè)批量作業(yè)節(jié)點(diǎn)中每個(gè)待處理作業(yè)的執(zhí)行順序?yàn)椴⑿袌?zhí)行；

第一確定模塊，用于根據(jù)所述當(dāng)前屬性信息中的業(yè)務(wù)數(shù)據(jù)量確定對(duì)應(yīng)待處理作業(yè)的執(zhí)行時(shí)間；

調(diào)整模塊，用于根據(jù)所述執(zhí)行時(shí)間實(shí)時(shí)調(diào)整對(duì)應(yīng)待處理作業(yè)在所述當(dāng)前批量作業(yè)節(jié)點(diǎn)中的執(zhí)行順序；

執(zhí)行模塊，用于按照所述執(zhí)行順序執(zhí)行所述當(dāng)前批量作業(yè)節(jié)點(diǎn)中的所有待處理作業(yè)。

第三方面，本發(fā)明實(shí)施例還提供了一種批量作業(yè)執(zhí)行設(shè)備，該設(shè)備包括：存儲(chǔ)器，以及一個(gè)或多個(gè)處理器；

存儲(chǔ)器，用于存儲(chǔ)一個(gè)或多個(gè)程序；

當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行，使得所述一個(gè)或多個(gè)處理器實(shí)現(xiàn)如上述任一實(shí)施例所述的批量作業(yè)執(zhí)行方法。

第四方面，一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，該程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)如上述任一實(shí)施例所述的批量作業(yè)執(zhí)行方法。