[發明專利]基于Argo的工作流連續調度方法和裝置

在審

• 申請號: 202210072068.5
• 申請日: 2022-01-21
• 公開（公告）號: CN114625498A
• 公開（公告）日: 2022-06-14
• 發明（設計）人: 趙永旺;李強;王超
• 申請（專利權）人: 浪潮通信技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/54
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 李文清

本發明涉及基于Argo的工作流連續調度方法和裝置，包括：根據工作流模板，生成應用實例對應的工作流代碼文件和argo events資源；其中，工作流模板包含第一工作流腳本片段和觸發第二工作流的腳本片段；觸發第二工作流的腳本片段，配置了第一工作流向第二工作流傳參時的傳參方式以及傳參參數項；利用工作流代碼文件和argo events資源，實現第一工作流與第二工作流之間的連續調度。本發明通過工作流模板生成不同的工作流實例，解決工作流單一化，不可重用的問題，降低了開發成本；另外工作流模板增加觸發下一工作流的代碼片段，解決了工作流之間的調用需要手工執行的問題，實現不同工作流的自動調用。

技術領域

本發明涉及容器編排領域，尤其涉及一種基于Argo的工作流連續調度方法和裝置。

背景技術

Argo(容器本地工作流引擎)是一個基于kubernetes CRD(自定義資源)實現的一個Workflow(工作流)開源工具，它基于kubernetes的調度能力實現了工作流的控制和任務的運行。

但是，Argo側重于工作流任務的調度，多工作流之間的調度以及參數傳遞，大多是通過手動實現，消耗人力成本且不利于調度的靈活性。

發明內容

本發明的目的是提供一種基于Argo的工作流連續調度方法和裝置，以解決需要手動實現多工作流之間的調度以及參數傳遞的問題，從而使工作流之間的調度更加靈活。

第一個方面，本發明實施例提供一種基于Argo的工作流連續調度方法，包括：

獲取工作流模板；其中，所述工作流模板包含第一工作流腳本片段和觸發第二工作流的腳本片段；所述觸發第二工作流的腳本片段，配置了第一工作流向第二工作流傳參時的傳參方式以及傳參參數項；

根據所述工作流模板，生成應用實例對應的工作流代碼文件和argo events資源；

利用所述工作流代碼文件和所述argo events資源，實現第一工作流與第二工作流之間的連續調度。

根據本發明提供的基于Argo的工作流連續調度方法，所述第一工作流腳本片段，通過容器編排方式定義了第一工作流的任務以及任務之間的依賴關系；所述任務包括任務名稱、任務參數、任務參數值和任務執行邏輯；

所述傳參方式，是通過curl命令中webhook接口的API地址，調用webhook接口，以利用webhook接口實現第一工作流與第二工作流之間的參數傳遞；

所述第一工作流腳本片段和所述觸發第二工作流的腳本片段，編輯了用于指代應用實例的應用實例編號；

所述工作流模板中curl命令中webhook接口的API地址、應用實例編號和任務參數值，均是以參數占位符填充的。

根據本發明提供的基于Argo的工作流連續調度方法，所述根據所述工作流模板，生成與應用實例對應的工作流代碼文件和argo events資源，包括：

綁定工作流模板與應用實例，以得到實例化工作流模板；

通過工作流服務接口調用argo events服務，以使argo events服務按照實例化工作流模板創建應用實例對應的argo events資源；其中，所述argo events資源包括：定時任務、第一觸發器、第二觸發器和webhook接口；

將所述curl命令給定的webhook接口的API地址替換為創建的webhook接口的API地址，進而得到應用實例對應的工作流代碼文件；

其中，所述第一觸發器，具備監聽所述定時任務以及觸發第一工作流執行的功能；

所述第二觸發器，具備監聽所述創建的webhook接口以及觸發第二工作流執行的功能。