[發(fā)明專利]一種任務(wù)管理的方法和裝置

在審

• 申請?zhí)枺?/td>: 201911115455.7
• 申請日: 2019-11-14
• 公開（公告）號: CN112799797A
• 公開（公告）日: 2021-05-14
• 發(fā)明（設(shè)計）人: 岳寶;范翔;徐文勝;王浩;劉洋;鄧丹
• 申請（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F21/52
• 代理公司: 中原信達知識產(chǎn)權(quán)代理有限責任公司 11219
• 代理人: 張一軍;張效榮

本發(fā)明公開了一種任務(wù)管理的方法和裝置，涉及計算機技術(shù)領(lǐng)域。該方法的一具體實施方式包括：接收任務(wù)執(zhí)行請求，解析任務(wù)的任務(wù)類型；根據(jù)所述任務(wù)類型和預(yù)設(shè)匹配關(guān)系，確定與所述任務(wù)類型對應(yīng)的DAG工作流；基于所述DAG工作流執(zhí)行所述任務(wù)。該實施方式能夠使業(yè)務(wù)框架與業(yè)務(wù)場景解耦，降低代碼復(fù)雜度，提高業(yè)務(wù)框架的通用性。

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

本發(fā)明涉及計算機技術(shù)領(lǐng)域，尤其涉及一種任務(wù)管理的方法和裝置。

背景技術(shù)

業(yè)務(wù)流程一般有對個階段，每個階段往往涉及業(yè)務(wù)系統(tǒng)中的多個業(yè)務(wù)處理模塊，大部分模塊含有同步或異步調(diào)用外部服務(wù)的場景。如果按照面向過程的編程思路設(shè)計業(yè)務(wù)框架，代碼邏輯會陷入很長的異步回調(diào)陷阱，使得代碼非常難以理解和修改。因此，實際應(yīng)用過程中一般針對具體場景設(shè)計對應(yīng)的業(yè)務(wù)框架。

在實現(xiàn)本發(fā)明過程中，發(fā)明人發(fā)現(xiàn)現(xiàn)有技術(shù)中至少存在如下問題：

業(yè)務(wù)框架與業(yè)務(wù)場景耦合太緊，代碼復(fù)雜度高，且無法適用于其他業(yè)務(wù)場景，通用性差。

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

有鑒于此，本發(fā)明實施例提供一種任務(wù)管理的方法和裝置，能夠使業(yè)務(wù)框架與業(yè)務(wù)場景解耦，降低代碼復(fù)雜度，提高業(yè)務(wù)框架的通用性。

為實現(xiàn)上述目的，根據(jù)本發(fā)明實施例的一個方面，提供了一種任務(wù)管理的方法，包括：

接收任務(wù)執(zhí)行請求，解析任務(wù)的任務(wù)類型；

根據(jù)所述任務(wù)類型和預(yù)設(shè)匹配關(guān)系，確定與所述任務(wù)類型對應(yīng)的DAG工作流；

基于所述DAG工作流執(zhí)行所述任務(wù)。

可選地，確定與所述任務(wù)類型對應(yīng)的DAG工作流之后，還包括：對所述DAG工作流進行合法性校驗并確認校驗通過。

可選地，所述DAG工作流中各個節(jié)點中的至少一個標記為開始節(jié)點，至少另一個標記為最終節(jié)點；

基于所述有向無環(huán)圖處理所述待處理任務(wù)，包括：對于包括上述開始結(jié)點在內(nèi)的所述最終節(jié)點之前的任意一個節(jié)點，判斷所述任意一個節(jié)點是否執(zhí)行成功，若成功，則跳轉(zhuǎn)至任意一個節(jié)點的下一個節(jié)點；否則，跳轉(zhuǎn)至所述最終節(jié)點。

可選地，所述有向無環(huán)圖中各個節(jié)點中的至少一個位于所述最終節(jié)點之后。

可選地，所述各個節(jié)點包括以下至少之一：串行節(jié)點、并行節(jié)點、分片節(jié)點、條件節(jié)點。

根據(jù)本發(fā)明實施例的第二方面，提供一種任務(wù)管理的裝置，包括：

解析單元，接收任務(wù)執(zhí)行請求，解析任務(wù)的任務(wù)類型；

分發(fā)單元，根據(jù)所述任務(wù)類型和預(yù)設(shè)匹配關(guān)系，確定與所述任務(wù)類型對應(yīng)的DAG工作流；

執(zhí)行單元，基于所述DAG工作流執(zhí)行所述任務(wù)。

可選地，所述分發(fā)單元還用于：確定與所述任務(wù)類型對應(yīng)的DAG工作流之后，對所述DAG工作流進行合法性校驗并確認校驗通過。

可選地，所述DAG工作流中各個節(jié)點中的至少一個標記為開始節(jié)點，至少另一個標記為最終節(jié)點；

所述執(zhí)行單元基于所述有向無環(huán)圖處理所述待處理任務(wù)，包括：對于包括上述開始結(jié)點在內(nèi)的所述最終節(jié)點之前的任意一個節(jié)點，判斷所述任意一個節(jié)點是否執(zhí)行成功，若成功，則跳轉(zhuǎn)至任意一個節(jié)點的下一個節(jié)點；否則，跳轉(zhuǎn)至所述最終節(jié)點。

根據(jù)本發(fā)明實施例的第三方面，提供一種任務(wù)管理的電子設(shè)備，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執(zhí)行，使得所述一個或多個處理器實現(xiàn)本發(fā)明實施例第一方面提供的方法。