[發(fā)明專利]基于Argo的工作流連續(xù)調(diào)度方法和裝置

在審

• 申請?zhí)枺?/td>: 202210072068.5
• 申請日: 2022-01-21
• 公開（公告）號: CN114625498A
• 公開（公告）日: 2022-06-14
• 發(fā)明（設(shè)計）人: 趙永旺;李強;王超
• 申請（專利權(quán)）人: 浪潮通信技術(shù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/54
• 代理公司: 北京路浩知識產(chǎn)權(quán)代理有限公司 11002
• 代理人: 李文清

1.一種基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述方法包括：

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

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

利用所述工作流代碼文件和所述argo events資源，實現(xiàn)第一工作流與第二工作流之間的連續(xù)調(diào)度。

2.根據(jù)權(quán)利要求1所述的基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述第一工作流腳本片段，通過容器編排方式定義了第一工作流的任務(wù)以及任務(wù)之間的依賴關(guān)系；所述任務(wù)包括任務(wù)名稱、任務(wù)參數(shù)、任務(wù)參數(shù)值和任務(wù)執(zhí)行邏輯；

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

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

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

3.根據(jù)權(quán)利要求2所述的基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述根據(jù)所述工作流模板，生成與應(yīng)用實例對應(yīng)的工作流代碼文件和argo events資源，包括：

綁定工作流模板與應(yīng)用實例，以得到實例化工作流模板；

通過工作流服務(wù)接口調(diào)用argo events服務(wù)，以使argo events服務(wù)按照實例化工作流模板創(chuàng)建應(yīng)用實例對應(yīng)的argo events資源；其中，所述argo events資源包括：定時任務(wù)、第一觸發(fā)器、第二觸發(fā)器和webhook接口；

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

其中，所述第一觸發(fā)器，具備監(jiān)聽所述定時任務(wù)以及觸發(fā)第一工作流執(zhí)行的功能；

所述第二觸發(fā)器，具備監(jiān)聽所述創(chuàng)建的webhook接口以及觸發(fā)第二工作流執(zhí)行的功能。

4.根據(jù)權(quán)利要求3所述的基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述綁定工作流模板與應(yīng)用實例，以得到實例化工作流模板，包括：

在收到工作流模板與應(yīng)用實例綁定指令的情況下，為應(yīng)用實例自動生成應(yīng)用實例編號；

將所述工作流模板中的應(yīng)用實例編號替換為所述生成的應(yīng)用實例編號，同時將所述工作流模板中的任務(wù)參數(shù)值替換為應(yīng)用實例中的任務(wù)參數(shù)值，以得到實例化工作流模板。

5.根據(jù)權(quán)利要求4所述的基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述定時任務(wù)、所述第一觸發(fā)器、所述第二觸發(fā)器和所述創(chuàng)建的webhook接口，分別以應(yīng)用實例編號-定時任務(wù)、應(yīng)用實例編號-第一觸發(fā)器、應(yīng)用實例編號-第二觸發(fā)器和應(yīng)用實例編號-webhook接口的格式命名。

6.根據(jù)權(quán)利要求3或5所述的基于Argo的工作流連續(xù)調(diào)度方法，其特征在于，所述創(chuàng)建應(yīng)用實例對應(yīng)的定時任務(wù)之后，還包括：

為所述定時任務(wù)配置cron表達式；

其中，所述cron表達式，用于指示所述定時任務(wù)發(fā)出執(zhí)行指令。