[發(fā)明專利]一種批量作業(yè)監(jiān)控方法及裝置、設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202210127498.2
• 申請日: 2022-02-11
• 公開（公告）號(hào): CN114500318A
• 公開（公告）日: 2022-05-13
• 發(fā)明（設(shè)計(jì)）人: 曹琎;王亞軍;陳萬紅;邱楓
• 申請（專利權(quán)）人: 中國工商銀行股份有限公司
• 主分類號(hào): H04L43/08
• 分類號(hào): H04L43/08;H04L43/10;H04L43/16;H04L43/50;H04L41/0631
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 張博

本公開提供了一種批量作業(yè)監(jiān)控方法，應(yīng)用于金融、計(jì)算機(jī)技術(shù)領(lǐng)域，該方法包括：接收來自批量作業(yè)鏈路中的上游節(jié)點(diǎn)的作業(yè)報(bào)文；利用來自上游節(jié)點(diǎn)的作業(yè)報(bào)文，更新批量作業(yè)鏈路中當(dāng)前節(jié)點(diǎn)的作業(yè)報(bào)文，其中，當(dāng)前節(jié)點(diǎn)在批量作業(yè)鏈路中位于上游節(jié)點(diǎn)的下游；根據(jù)更新后的當(dāng)前節(jié)點(diǎn)的作業(yè)報(bào)文，獲取當(dāng)前節(jié)點(diǎn)的作業(yè)時(shí)長；在當(dāng)前節(jié)點(diǎn)的作業(yè)時(shí)長滿足預(yù)設(shè)時(shí)間閾值條件的情況下，發(fā)出預(yù)警信息。本公開還提供了一種批量作業(yè)監(jiān)控裝置、設(shè)備、存儲(chǔ)介質(zhì)和程序產(chǎn)品。

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

本公開涉及金融、計(jì)算機(jī)技術(shù)領(lǐng)域，具體涉及一種批量作業(yè)監(jiān)控方法、裝置、設(shè)備、介質(zhì)和程序產(chǎn)品。

背景技術(shù)

隨著銀行等金融行業(yè)信息化程度的不斷提高，用戶數(shù)量的不斷增加，后臺(tái)服務(wù)器產(chǎn)生的數(shù)據(jù)量大幅增長。此外，隨著銀行等信息科技部門后臺(tái)架構(gòu)的不斷升級(jí)調(diào)整，應(yīng)用系統(tǒng)間集成和信息交互的復(fù)雜度不斷提升，大量的應(yīng)用系統(tǒng)之間通過批量作業(yè)完成數(shù)據(jù)的交互同步，這對批量作業(yè)的性能處理需求提出了更高的要求。批量作業(yè)在傳輸中，因?yàn)榫W(wǎng)絡(luò)中斷，傳輸文件大小，批量節(jié)點(diǎn)服務(wù)器性能處理能力，批量文件格式等原因，會(huì)造成批量作業(yè)的延遲，甚至中斷，影響應(yīng)用系統(tǒng)間的批量文件傳輸和信息交互。目前的技術(shù)方案中，作業(yè)節(jié)點(diǎn)無法感知批量作業(yè)鏈路中上下游節(jié)點(diǎn)作業(yè)狀態(tài)，影響了批量作業(yè)效率，并推高了運(yùn)維成本。

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

鑒于上述問題，本公開提供了一種基于報(bào)文的批量作業(yè)監(jiān)控方法、裝置、設(shè)備、介質(zhì)和程序產(chǎn)品。

本公開的第一個(gè)方面，提供了一種批量作業(yè)監(jiān)控方法，包括：

接收來自批量作業(yè)鏈路中的上游節(jié)點(diǎn)的作業(yè)報(bào)文；

利用來自上游節(jié)點(diǎn)的作業(yè)報(bào)文，更新批量作業(yè)鏈路中當(dāng)前節(jié)點(diǎn)的作業(yè)報(bào)文，其中，當(dāng)前節(jié)點(diǎn)在批量作業(yè)鏈路中位于上游節(jié)點(diǎn)的下游；

根據(jù)更新后的當(dāng)前節(jié)點(diǎn)的作業(yè)報(bào)文，獲取當(dāng)前節(jié)點(diǎn)的作業(yè)時(shí)長；

在當(dāng)前節(jié)點(diǎn)的作業(yè)時(shí)長滿足預(yù)設(shè)時(shí)間閾值條件的情況下，發(fā)出預(yù)警信息。

根據(jù)本公開的實(shí)施例，上述作業(yè)報(bào)文包括批量作業(yè)工程名稱、作業(yè)節(jié)點(diǎn)名稱、作業(yè)文件大小、累計(jì)作業(yè)時(shí)長和報(bào)錯(cuò)節(jié)點(diǎn)名稱；

其中，作業(yè)文件大小表示作業(yè)節(jié)點(diǎn)待處理的文件大小；

其中，累計(jì)作業(yè)時(shí)長表示批量作業(yè)鏈路累計(jì)的作業(yè)時(shí)間；

其中，報(bào)錯(cuò)節(jié)點(diǎn)名稱用于記錄批量作業(yè)鏈路中發(fā)生作業(yè)中斷的節(jié)點(diǎn)名稱。

根據(jù)本公開的實(shí)施例，上述利用來自上游節(jié)點(diǎn)的作業(yè)報(bào)文，更新批量作業(yè)鏈路中當(dāng)前節(jié)點(diǎn)的作業(yè)報(bào)文包括以下至少之一：更新當(dāng)前節(jié)點(diǎn)的作業(yè)文件大小、更新當(dāng)前節(jié)點(diǎn)的累計(jì)作業(yè)時(shí)長以及更新當(dāng)前節(jié)點(diǎn)的報(bào)錯(cuò)節(jié)點(diǎn)名稱。

根據(jù)本公開的實(shí)施例，上述更新當(dāng)前節(jié)點(diǎn)的作業(yè)文件大小包括：

通過當(dāng)前節(jié)點(diǎn)獲取批量作業(yè)鏈路中各個(gè)上游節(jié)點(diǎn)的作業(yè)文件大小并進(jìn)行累加，獲得作業(yè)文件大小累加值；

通過當(dāng)前節(jié)點(diǎn)的歷史日志文件獲取轉(zhuǎn)發(fā)作業(yè)文件大小，其中，歷史日志文件用于記錄當(dāng)前節(jié)點(diǎn)的歷史作業(yè)信息，歷史日志文件包括歷史作業(yè)文件總數(shù)、歷史作業(yè)處理時(shí)長以及發(fā)送到下游節(jié)點(diǎn)的轉(zhuǎn)發(fā)作業(yè)文件大小；

利用局部加權(quán)線性回歸算法處理作業(yè)文件大小累加值和轉(zhuǎn)發(fā)作業(yè)文件大小，更新當(dāng)前節(jié)點(diǎn)的作業(yè)文件大小。

根據(jù)本公開的實(shí)施例，上述更新當(dāng)前節(jié)點(diǎn)的累計(jì)作業(yè)時(shí)長包括：

通過當(dāng)前節(jié)點(diǎn)的歷史日志文件獲取歷史作業(yè)處理時(shí)長；

通過局部加權(quán)線性回歸算法處理歷史作業(yè)處理時(shí)長和當(dāng)前節(jié)點(diǎn)的作業(yè)文件大小，確定當(dāng)前作業(yè)節(jié)點(diǎn)的處理時(shí)長；

通過當(dāng)前節(jié)點(diǎn)獲取批量作業(yè)鏈路中各個(gè)上游節(jié)點(diǎn)的累計(jì)作業(yè)時(shí)長并獲得上游節(jié)點(diǎn)累計(jì)作業(yè)時(shí)長的最大值；