[發(fā)明專利]批處理任務(wù)執(zhí)行方法、系統(tǒng)以及機(jī)房部署系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202010568593.7
• 申請日: 2020-06-19
• 公開（公告）號: CN111666144A
• 公開（公告）日: 2020-09-15
• 發(fā)明（設(shè)計(jì)）人: 劉娟;李軍剛;王志鋒;方錫銳;詹武州;喬雅正
• 申請（專利權(quán)）人: 中信銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京市蘭臺律師事務(wù)所 11354
• 代理人: 張峰

本發(fā)明提供一種批處理任務(wù)執(zhí)行方法、系統(tǒng)以及機(jī)房部署系統(tǒng)，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域。該方法包括：獲取多個(gè)批處理任務(wù)，按照預(yù)設(shè)規(guī)則將多個(gè)批處理任務(wù)編排為多個(gè)批次，并確定各批次批處理任務(wù)的執(zhí)行順序，其中，每個(gè)批次可以包括至少一個(gè)批處理任務(wù)，且每個(gè)批次的批處理任務(wù)具有相同或相近的任務(wù)屬性，按照各批次批處理任務(wù)的執(zhí)行順序，依次執(zhí)行各批次批處理任務(wù)。本發(fā)明通過將批處理任務(wù)按照預(yù)設(shè)規(guī)則編排為多個(gè)批次，且確定各批次批處理任務(wù)的執(zhí)行順序，并按照各批次批處理任務(wù)的執(zhí)行順序執(zhí)行批處理任務(wù)，可以實(shí)現(xiàn)對大量的批處理任務(wù)進(jìn)行有效地管理，從而滿足大量批處理任務(wù)的多次執(zhí)行需求。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，具體而言，涉及一種批處理任務(wù)執(zhí)行方法、系統(tǒng)以及機(jī)房部署系統(tǒng)。

背景技術(shù)

信用卡系統(tǒng)是集計(jì)算機(jī)、網(wǎng)絡(luò)通信、金融與商業(yè)電子化設(shè)備于一體的電子貨幣流通體系，指的是信用卡業(yè)務(wù)的處理軟件系統(tǒng)。信用卡系統(tǒng)可以以機(jī)構(gòu)、持卡人、賬戶、卡片為核心，對它們之間的各種業(yè)務(wù)關(guān)系進(jìn)行處理。機(jī)構(gòu)可以為持卡人提供各種卡片，持卡人可以申請相應(yīng)的卡片、并享有該卡片的各種服務(wù)。信用卡系統(tǒng)中可以對發(fā)卡、制卡、客戶服務(wù)、分期服務(wù)、交易服務(wù)、資產(chǎn)證券化、國際卡組織清算、對賬服務(wù)等賬戶處理任務(wù)進(jìn)行處理。

但是，隨著信息數(shù)據(jù)的增長，批處理任務(wù)不斷增加，導(dǎo)致現(xiàn)有的批處理任務(wù)執(zhí)行方式不能夠?qū)Υ罅康呐幚砣蝿?wù)進(jìn)行有效地管理，無法滿足大量批處理任務(wù)的多次執(zhí)行需求。

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

本發(fā)明提供一種批處理任務(wù)執(zhí)行方法、系統(tǒng)以及機(jī)房部署系統(tǒng)，可以對大量的批處理任務(wù)進(jìn)行有效地管理，滿足大量批處理任務(wù)的多次執(zhí)行需求。

第一方面，本發(fā)明實(shí)施例提供一種批處理任務(wù)執(zhí)行方法，所述方法包括：獲取多個(gè)批處理任務(wù)；按照預(yù)設(shè)規(guī)則將多個(gè)所述批處理任務(wù)編排為多個(gè)批次，并確定各批次批處理任務(wù)的執(zhí)行順序；其中，每個(gè)批次可以包括至少一個(gè)批處理任務(wù)，且每個(gè)批次的批處理任務(wù)具有相同或相近的任務(wù)屬性；按照所述各批次批處理任務(wù)的執(zhí)行順序，依次執(zhí)行所述各批次批處理任務(wù)。

可選地，所述按照預(yù)設(shè)規(guī)則將多個(gè)所述批處理任務(wù)編排為多個(gè)批次，并確定各批次批處理任務(wù)的執(zhí)行順序，包括：根據(jù)各所述批處理任務(wù)所屬的業(yè)務(wù)維度或數(shù)據(jù)流維度，將多個(gè)所述批處理任務(wù)編排為多個(gè)批次；按照預(yù)設(shè)的優(yōu)先級規(guī)則，分別確定各批次批處理任務(wù)的優(yōu)先級；根據(jù)所述各批次批處理任務(wù)的優(yōu)先級，確定所述各批次批處理任務(wù)的執(zhí)行順序。

可選地，所述根據(jù)所述各批次批處理任務(wù)的優(yōu)先級，確定所述各批次批處理任務(wù)的執(zhí)行順序之前，所述方法還包括：計(jì)算獲取各批次批處理任務(wù)的資源消耗量；所述根據(jù)所述各批次批處理任務(wù)的優(yōu)先級，確定所述各批次批處理任務(wù)的執(zhí)行順序，包括：根據(jù)所述各批次批處理任務(wù)的優(yōu)先級、以及資源消耗量，確定所述各批次批處理任務(wù)的執(zhí)行順序。

可選地，所述按照所述各批次批處理任務(wù)的執(zhí)行順序，依次執(zhí)行所述各批次批處理任務(wù)之前，所述方法還包括：通過離線同步的方式將賬戶系統(tǒng)和授權(quán)系統(tǒng)的數(shù)據(jù)同步至分布式集群；所述按照所述各批次批處理任務(wù)的執(zhí)行順序，依次執(zhí)行所述各批次批處理任務(wù)，包括：按照所述各批次批處理任務(wù)的執(zhí)行順序，基于所述分布式集群中所述賬戶系統(tǒng)和所述授權(quán)系統(tǒng)的數(shù)據(jù)，依次執(zhí)行所述各批次批處理任務(wù)。

可選地，所述獲取多個(gè)批處理任務(wù)之前，所述方法還包括：輪詢批處理啟動(dòng)條件；所述獲取多個(gè)批處理任務(wù)，包括：獲取滿足批處理啟動(dòng)條件的多個(gè)批處理任務(wù)。

第二方面，本發(fā)明實(shí)施例提供一種批處理任務(wù)執(zhí)行系統(tǒng)，所述系統(tǒng)包括：批處理任務(wù)獲取模塊，用于獲取多個(gè)批處理任務(wù)；批處理任務(wù)編排模塊，用于按照預(yù)設(shè)規(guī)則將多個(gè)所述批處理任務(wù)編排為多個(gè)批次，并確定各批次批處理任務(wù)的執(zhí)行順序；其中，每個(gè)批次可以包括至少一個(gè)批處理任務(wù)，且每個(gè)批次的批處理任務(wù)具有相同或相近的任務(wù)屬性；執(zhí)行模塊，用于按照所述各批次批處理任務(wù)的執(zhí)行順序，依次執(zhí)行所述各批次批處理任務(wù)。