[發明專利]一種DAG數據模型動態調度方法及系統

在審

• 申請號: 202210151260.3
• 申請日: 2022-02-18
• 公開（公告）號: CN114675948A
• 公開（公告）日: 2022-06-28
• 發明（設計）人: 劉志海;陳聰金
• 申請（專利權）人: 珠海紫訊信息科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/448
• 代理公司: 福州市鼓樓區京華專利事務所(普通合伙) 35212
• 代理人: 王美花

1.一種DAG數據模型動態調度方法，其特征在于：包括如下步驟：

步驟S10、對任務節點進行可視化編排得到DAG數據模型；

步驟S20、對所述DAG數據模型進行校驗；

步驟S30、對校驗通過后的所述DAG數據模型的各任務節點進行參數以及變量的配置；

步驟S40、基于所述DAG數據模型中各任務節點攜帶的調度邏輯以及上一個任務節點的運行數據，動態調度下一個所述任務節點，直至完成任務調度。

2.如權利要求1所述的一種DAG數據模型動態調度方法，其特征在于：所述步驟S10具體為：

以流程圖模式創建若干個攜帶任務信息的任務節點，對各所述任務節點進行拖拽以及連線的可視化編排，設定各所述任務節點的調度順序，存儲各所述任務節點的任務信息、連接關系以及調度順序，進而得到DAG數據模型；

所述任務信息至少包括節點ID、任務名稱、任務屬性、任務內容以及調度邏輯。

3.如權利要求1所述的一種DAG數據模型動態調度方法，其特征在于：所述步驟S20具體為：

對所述DAG數據模型中的各任務節點進行遍歷，判斷是否存在閉環回路，若是，則校驗失敗，突出顯示所述閉環回路對應的任務節點，并進行告警提示；若否，則校驗成功，并進入步驟S30。

4.如權利要求1所述的一種DAG數據模型動態調度方法，其特征在于：所述步驟S30中，所述參數至少包括參數名稱、參數方向、參數類型、默認值以及取值范圍；所述參數方向為傳入或者傳出；

所述變量至少包括變量名稱、變量類型以及默認值。

5.如權利要求2所述的一種DAG數據模型動態調度方法，其特征在于：所述步驟S40具體包括：

步驟S41、任務調度器通過所述DAG數據模型中的調度順序查找起始的任務節點，從起始的所述任務節點開始進行調度，獲取所述任務節點的運行數據，并將各所述運行數據輸出至下一個任務節點；

步驟S42、基于所述調度順序判斷下一個任務節點是否存在分支，若是，則基于所述調度邏輯以及上一個任務節點的運行數據動態選擇下一個調度的任務節點，并進入步驟S43；若否，則基于所述調度順序直接調度下一個任務節點，并進入步驟S43；

步驟S43、基于所述調度順序判斷是否還存在下一個任務節點，若是，則進入步驟S42；若否，則完成任務調度。

6.一種DAG數據模型動態調度系統，其特征在于：包括如下模塊：

任務節點編排模塊，用于對任務節點進行可視化編排得到DAG數據模型；

DAG數據模型校驗模塊，用于對所述DAG數據模型進行校驗；

參數及變量配置模塊，用于對校驗通過后的所述DAG數據模型的各任務節點進行參數以及變量的配置；

動態調度模塊，用于基于所述DAG數據模型中各任務節點攜帶的調度邏輯以及上一個任務節點的運行數據，動態調度下一個所述任務節點，直至完成任務調度。

7.如權利要求6所述的一種DAG數據模型動態調度系統，其特征在于：所述任務節點編排模塊具體為：

以流程圖模式創建若干個攜帶任務信息的任務節點，對各所述任務節點進行拖拽以及連線的可視化編排，設定各所述任務節點的調度順序，存儲各所述任務節點的任務信息、連接關系以及調度順序，進而得到DAG數據模型；

所述任務信息至少包括節點ID、任務名稱、任務屬性、任務內容以及調度邏輯。

8.如權利要求6所述的一種DAG數據模型動態調度系統，其特征在于：所述DAG數據模型校驗模塊具體為：

對所述DAG數據模型中的各任務節點進行遍歷，判斷是否存在閉環回路，若是，則校驗失敗，突出顯示所述閉環回路對應的任務節點，并進行告警提示；若否，則校驗成功，并進入參數及變量配置模塊。