[發(fā)明專利]任務(wù)節(jié)點(diǎn)管理方法以及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202010088814.0
• 申請(qǐng)日: 2020-02-12
• 公開（公告）號(hào): CN111291123A
• 公開（公告）日: 2020-06-16
• 發(fā)明（設(shè)計(jì)）人: 楊寶江
• 申請(qǐng)（專利權(quán)）人: 支付寶（杭州）信息技術(shù)有限公司
• 主分類號(hào): G06F16/27
• 分類號(hào): G06F16/27;G06F16/25
• 代理公司: 北京智信禾專利代理有限公司 11637
• 代理人: 李曉慶

本說明書實(shí)施例提供任務(wù)節(jié)點(diǎn)管理方法以及裝置，其中所述任務(wù)節(jié)點(diǎn)管理方法包括：獲取任務(wù)鏈路中任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息，其中，所述任務(wù)節(jié)點(diǎn)與基于任務(wù)信息創(chuàng)建的任務(wù)實(shí)例對(duì)應(yīng)；將所述標(biāo)識(shí)信息作為調(diào)用參數(shù)調(diào)用數(shù)據(jù)查詢接口進(jìn)行數(shù)據(jù)查詢，并從所述數(shù)據(jù)查詢接口返回的查詢結(jié)果中確定所述任務(wù)節(jié)點(diǎn)的上游任務(wù)節(jié)點(diǎn)；判斷所述任務(wù)節(jié)點(diǎn)以及所述上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)；若存在，則針對(duì)所述目標(biāo)任務(wù)節(jié)點(diǎn)進(jìn)行預(yù)警提示。

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

本說明書實(shí)施例涉及計(jì)算機(jī)技術(shù)領(lǐng)域，特別涉及一種任務(wù)節(jié)點(diǎn)管理方法。本說明書一個(gè)或者多個(gè)實(shí)施例同時(shí)涉及一種任務(wù)節(jié)點(diǎn)管理裝置，一種計(jì)算設(shè)備，以及一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

大數(shù)據(jù)技術(shù)是近年來發(fā)展極為迅速的一個(gè)領(lǐng)域，是支撐現(xiàn)代互聯(lián)網(wǎng)廣告以及電子商務(wù)等主流互聯(lián)網(wǎng)業(yè)務(wù)的重要基石，一個(gè)互聯(lián)網(wǎng)業(yè)務(wù)的背后，通常有成千上萬的大數(shù)據(jù)處理任務(wù)作為支撐，而這些任務(wù)之間的關(guān)系錯(cuò)綜復(fù)雜。

大數(shù)據(jù)背景下，大批量的數(shù)據(jù)產(chǎn)出都是通過發(fā)布多個(gè)任務(wù)，任務(wù)按天生產(chǎn)實(shí)例后實(shí)例運(yùn)行的結(jié)果，每個(gè)任務(wù)實(shí)例其上游都可能是一個(gè)相互依賴的網(wǎng)狀結(jié)構(gòu)，在一個(gè)業(yè)務(wù)周期內(nèi)有多個(gè)任務(wù)時(shí)，若各個(gè)基于任務(wù)信息創(chuàng)建的任務(wù)實(shí)例在運(yùn)行過程中其輸入輸出均存在依賴關(guān)系，則各個(gè)任務(wù)實(shí)例需順序運(yùn)行，業(yè)務(wù)越復(fù)雜，則任務(wù)實(shí)例整體運(yùn)行耗時(shí)也越久，效率越低。

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

有鑒于此，本說明書實(shí)施例提供了一種任務(wù)節(jié)點(diǎn)管理方法。本說明書一個(gè)或者多個(gè)實(shí)施例同時(shí)涉及一種任務(wù)節(jié)點(diǎn)管理裝置，一種計(jì)算設(shè)備，以及一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，以解決現(xiàn)有技術(shù)中存在的技術(shù)缺陷。

根據(jù)本說明書實(shí)施例的第一方面，提供了一種任務(wù)節(jié)點(diǎn)管理方法，包括：

獲取任務(wù)鏈路中任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息，其中，所述任務(wù)節(jié)點(diǎn)與基于任務(wù)信息創(chuàng)建的任務(wù)實(shí)例對(duì)應(yīng)；

將所述標(biāo)識(shí)信息作為調(diào)用參數(shù)調(diào)用數(shù)據(jù)查詢接口進(jìn)行數(shù)據(jù)查詢，并從所述數(shù)據(jù)查詢接口返回的查詢結(jié)果中確定所述任務(wù)節(jié)點(diǎn)的上游任務(wù)節(jié)點(diǎn)；

判斷所述任務(wù)節(jié)點(diǎn)以及所述上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)；

若是，則針對(duì)所述目標(biāo)任務(wù)節(jié)點(diǎn)進(jìn)行預(yù)警提示。

可選地，若所述判斷所述任務(wù)節(jié)點(diǎn)以及所述上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)步驟的執(zhí)行結(jié)果為否，則執(zhí)行如下操作：

將所述上游任務(wù)節(jié)點(diǎn)作為基礎(chǔ)任務(wù)節(jié)點(diǎn)，并在所述查詢結(jié)果中讀取所述基礎(chǔ)任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息；

將所述基礎(chǔ)任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息作為調(diào)用參數(shù)調(diào)用所述數(shù)據(jù)查詢接口進(jìn)行數(shù)據(jù)查詢，并從所述數(shù)據(jù)查詢接口返回的任務(wù)節(jié)點(diǎn)查詢結(jié)果中確定所述基礎(chǔ)任務(wù)節(jié)點(diǎn)所在層級(jí)的上一層級(jí)的上游任務(wù)節(jié)點(diǎn)；

判斷所述基礎(chǔ)任務(wù)節(jié)點(diǎn)以及所述上一層級(jí)的上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)；

若是，則針對(duì)所述目標(biāo)任務(wù)節(jié)點(diǎn)進(jìn)行預(yù)警提示。

可選地，若所述判斷所述基礎(chǔ)任務(wù)節(jié)點(diǎn)以及所述上一層級(jí)的上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)步驟的執(zhí)行結(jié)果為否，則執(zhí)行如下操作：

將所述上一層級(jí)的上游任務(wù)節(jié)點(diǎn)作為基礎(chǔ)任務(wù)節(jié)點(diǎn)，并在所述查詢結(jié)果中讀取所述基礎(chǔ)任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息；

返回執(zhí)行所述將所述基礎(chǔ)任務(wù)節(jié)點(diǎn)的標(biāo)識(shí)信息作為調(diào)用參數(shù)調(diào)用所述數(shù)據(jù)查詢接口進(jìn)行數(shù)據(jù)查詢，并從所述數(shù)據(jù)查詢接口返回的任務(wù)節(jié)點(diǎn)查詢結(jié)果中確定所述基礎(chǔ)任務(wù)節(jié)點(diǎn)所在層級(jí)的上一層級(jí)的上游任務(wù)節(jié)點(diǎn)的步驟；

其中，所述基礎(chǔ)任務(wù)節(jié)點(diǎn)與所述上一層級(jí)的上游任務(wù)節(jié)點(diǎn)各自對(duì)應(yīng)的任務(wù)實(shí)例在運(yùn)行過程中存在依賴關(guān)系。

可選地，若所述判斷所述基礎(chǔ)任務(wù)節(jié)點(diǎn)以及所述上一層級(jí)的上游任務(wù)節(jié)點(diǎn)中是否存在標(biāo)識(shí)信息相同的目標(biāo)任務(wù)節(jié)點(diǎn)步驟的執(zhí)行結(jié)果為否，則執(zhí)行如下操作：