[發明專利]工作流依賴管理方法、裝置、計算機設備及存儲介質

在審

• 申請號: 202011483709.3
• 申請日: 2020-12-16
• 公開（公告）號: CN112596873A
• 公開（公告）日: 2021-04-02
• 發明（設計）人: 李響
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 蔣學超

本發明實施例公開了一種工作流依賴管理方法、裝置、計算機設備及存儲介質，涉及區塊鏈領域。方法包括：判斷待執行工作流是否包含預配置的依賴屬性；若待執行工作流包含依賴屬性，在預設的消息集群中訂閱待執行工作流依賴的工作流的執行完成消息；判斷是否接收到消息集群發送的待執行工作流依賴的工作流的執行完成消息；若接收到消息集群發送的待執行工作流依賴的工作流的執行完成消息，執行待執行工作流。通過在消息集群中訂閱待執行工作流依賴的工作流的執行完成消息，實現實時監控待執行工作流依賴的工作流的執行情況，整個過程無需調度服務器介入，各工作流能夠自動準確、高效有序的運行，減少了計算成本，還能有效降低出錯率。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種工作流依賴管理方法、裝置、計算機設備及存儲介質。

背景技術

一套完整的大數據服務平臺內部的應用，通常都是由大量任務單元組成的。例如，shell腳本，java程序，mapreduce程序、hive腳本以及spark程序等，各任務單元之間存在時間先后及前后依賴關系，為了很好地組織起這樣的復雜執行計劃，需要一個工作流調度系統來調度執行。

Azkaban是由Linkedin公司推出的一個開源分布式批量工作流任務調度器，用于在一個工作流內以一個特定的順序運行一組工作和流程。現有技術中，需要單獨設置調度服務器，由調度服務器統一調度各在工作流之間的執行順序，各執行服務器只需等待調度服務器的處理指令。隨著系統的復雜度提高，工作流變得越來越多，工作流之間的依賴關系及其復雜，調度服務器的計算量極其巨大，并且調度規則，需要人為配置，極易出錯。

發明內容

本發明實施例提供了一種工作流依賴管理方法、裝置、計算機設備及存儲介質，旨在解決現有工作流調度方式計算量大且極易調度出錯的問題。

第一方面，本發明實施例提供了一種工作流依賴管理方法，其包括：

判斷待執行工作流是否包含預配置的依賴屬性，所述依賴屬性包含待執行工作流依賴的工作流的名稱；

若所述待執行工作流包含依賴屬性，在預設的消息集群中訂閱所述待執行工作流依賴的工作流的執行完成消息；

判斷是否接收到所述消息集群發送的所述待執行工作流依賴的工作流的執行完成消息；

若接收到所述消息集群發送的所述待執行工作流依賴的工作流的執行完成消息，執行所述待執行工作流。

第二方面，本發明實施例還提供了一種工作流依賴管理裝置，其包括：

第一判斷單元，用于判斷待執行工作流是否包含預配置的依賴屬性，所述依賴屬性包含待執行工作流依賴的工作流的名稱；

訂閱單元，用于若所述待執行工作流包含依賴屬性，在預設的消息集群中訂閱所述待執行工作流依賴的工作流的執行完成消息；

第二判斷單元，用于判斷是否接收到所述消息集群發送的所述待執行工作流依賴的工作流的執行完成消息；

第一執行單元，用于若接收到所述消息集群發送的所述待執行工作流依賴的工作流的執行完成消息，執行所述待執行工作流

第三方面，本發明實施例還提供了一種計算機設備，其包括存儲器及處理器，所述存儲器上存儲有計算機程序，所述處理器執行所述計算機程序時實現上述方法。

第四方面，本發明實施例還提供了一種計算機可讀存儲介質，所述存儲介質存儲有計算機程序，所述計算機程序當被處理器執行時可實現上述方法。