[發(fā)明專利]數(shù)據(jù)中臺(tái)的任務(wù)流控制方法及相關(guān)裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202110721920.2
• 申請(qǐng)日: 2021-06-28
• 公開（公告）號(hào): CN113434323A
• 公開（公告）日: 2021-09-24
• 發(fā)明（設(shè)計(jì)）人: 陶程飛;袁博;孫蕊蕊;周明偉;李叢
• 申請(qǐng)（專利權(quán)）人: 浙江大華技術(shù)股份有限公司
• 主分類號(hào): G06F11/07
• 分類號(hào): G06F11/07;G06F9/48
• 代理公司: 北京同達(dá)信恒知識(shí)產(chǎn)權(quán)代理有限公司 11291
• 代理人: 王英

1.一種數(shù)據(jù)中臺(tái)的任務(wù)流控制方法，其特征在于，所述方法包括：

第一任務(wù)節(jié)點(diǎn)基于第二任務(wù)節(jié)點(diǎn)的上下文信息確定操作類型，所述操作類型包括繼續(xù)執(zhí)行業(yè)務(wù)流或執(zhí)行告警操作；所述第一任務(wù)節(jié)點(diǎn)為所述第二任務(wù)節(jié)點(diǎn)的下游節(jié)點(diǎn)，所述上下文信息用于描述所述第二任務(wù)節(jié)點(diǎn)的任務(wù)執(zhí)行狀況；

所述第一任務(wù)節(jié)點(diǎn)基于所述操作類型，執(zhí)行任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述上下文信息是所述第二任務(wù)節(jié)點(diǎn)在執(zhí)行任務(wù)結(jié)束時(shí)，基于任務(wù)執(zhí)行結(jié)果生成并保存的；

其中，若所述第二任務(wù)節(jié)點(diǎn)為父節(jié)點(diǎn)，則所述第二任務(wù)節(jié)點(diǎn)基于預(yù)先配置的觸發(fā)規(guī)則，觸發(fā)執(zhí)行任務(wù)；

若所述第二任務(wù)節(jié)點(diǎn)為子節(jié)點(diǎn)，則所述第二任務(wù)節(jié)點(diǎn)基于第三任務(wù)節(jié)點(diǎn)的上下文信息觸發(fā)執(zhí)行任務(wù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一任務(wù)節(jié)點(diǎn)基于所述操作類型，執(zhí)行任務(wù)，包括：

所述第一任務(wù)節(jié)點(diǎn)依照所述第一任務(wù)節(jié)點(diǎn)的類型，基于所述第二任務(wù)節(jié)點(diǎn)的上下文信息執(zhí)行與所述第一任務(wù)節(jié)點(diǎn)的類型對(duì)應(yīng)的任務(wù)。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述依照所述第一任務(wù)節(jié)點(diǎn)的類型，基于所述第二任務(wù)節(jié)點(diǎn)的上下文信息執(zhí)行與所述第一任務(wù)節(jié)點(diǎn)的類型對(duì)應(yīng)的任務(wù)，包括：

若所述第一任務(wù)節(jié)點(diǎn)的類型為分支節(jié)點(diǎn)，則基于所述第二任務(wù)節(jié)點(diǎn)的上下文信息判斷是否滿足所述第一任務(wù)節(jié)點(diǎn)的多個(gè)下游節(jié)點(diǎn)中任一下游節(jié)點(diǎn)的執(zhí)行條件，若滿足，則觸發(fā)滿足執(zhí)行條件的下游節(jié)點(diǎn)執(zhí)行任務(wù)；

若不滿足所有下游節(jié)點(diǎn)的執(zhí)行條件，則基于預(yù)設(shè)的觸發(fā)告警規(guī)則，執(zhí)行告警操作。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述依照所述第一任務(wù)節(jié)點(diǎn)的類型，基于所述第二任務(wù)節(jié)點(diǎn)的上下文信息執(zhí)行與所述第一任務(wù)節(jié)點(diǎn)的類型對(duì)應(yīng)的任務(wù)，包括：

若所述第一任務(wù)節(jié)點(diǎn)的類型為歸并節(jié)點(diǎn)，且所述第一任務(wù)節(jié)點(diǎn)基于所述上下文信息確定所述第二任務(wù)節(jié)點(diǎn)執(zhí)行失敗，則所述第一任務(wù)節(jié)點(diǎn)基于所述上下文信息中的執(zhí)行結(jié)果確定是否滿足觸發(fā)下游節(jié)點(diǎn)的歸并條件，若滿足所述歸并條件，則觸發(fā)下游節(jié)點(diǎn)繼續(xù)執(zhí)行任務(wù)；

若不滿足所述歸并條件，則基于預(yù)設(shè)的觸發(fā)告警規(guī)則，執(zhí)行告警操作。

6.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述依照所述第一任務(wù)節(jié)點(diǎn)的類型，基于所述第二任務(wù)節(jié)點(diǎn)的上下文信息執(zhí)行與所述第一任務(wù)節(jié)點(diǎn)的類型對(duì)應(yīng)的任務(wù)，包括：

若所述第一任務(wù)節(jié)點(diǎn)的類型為質(zhì)量校驗(yàn)節(jié)點(diǎn)，則所述第一任務(wù)節(jié)點(diǎn)獲取所述上下文信息中包括的所述第二任務(wù)節(jié)點(diǎn)的執(zhí)行結(jié)果；

識(shí)別所述執(zhí)行結(jié)果是否符合標(biāo)準(zhǔn)要求；

若不符合標(biāo)準(zhǔn)要求則基于預(yù)設(shè)的觸發(fā)告警規(guī)則，執(zhí)行告警操作。

7.根據(jù)權(quán)利要求4-6中任一所述的方法，其特征在于，所述預(yù)設(shè)的觸發(fā)告警規(guī)則支持自定義。

8.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述上下文信息包括：執(zhí)行狀態(tài)、執(zhí)行耗時(shí)和執(zhí)行結(jié)果。

9.一種數(shù)據(jù)中臺(tái)的任務(wù)流控制裝置，其特征在于，應(yīng)用于第一任務(wù)節(jié)點(diǎn)，所述裝置包括：

操作類型確定模塊，用于基于第二任務(wù)節(jié)點(diǎn)的上下文信息確定操作類型，所述操作類型包括繼續(xù)執(zhí)行業(yè)務(wù)流或執(zhí)行告警操作；所述第一任務(wù)節(jié)點(diǎn)為所述第二任務(wù)節(jié)點(diǎn)的下游節(jié)點(diǎn)，所述上下文信息用于描述所述第二任務(wù)節(jié)點(diǎn)的任務(wù)執(zhí)行狀況；

執(zhí)行模塊，用于基于所述操作類型，執(zhí)行任務(wù)。

10.根據(jù)權(quán)利要求9所述的裝置，其特征在于，其特征在于，所述上下文信息是所述第二任務(wù)節(jié)點(diǎn)在執(zhí)行任務(wù)結(jié)束時(shí)，基于任務(wù)執(zhí)行結(jié)果生成并保存的；其中，若所述第二任務(wù)節(jié)點(diǎn)為父節(jié)點(diǎn)，則所述第二任務(wù)節(jié)點(diǎn)基于預(yù)先配置的觸發(fā)規(guī)則，觸發(fā)執(zhí)行任務(wù)；

若所述第二任務(wù)節(jié)點(diǎn)為子節(jié)點(diǎn)，則所述第二任務(wù)節(jié)點(diǎn)基于第三任務(wù)節(jié)點(diǎn)的上下文信息觸發(fā)執(zhí)行任務(wù)。