[發明專利]一種面向系統辨識的容器化云工作流處理系統及方法

在審

• 申請號: 202110561275.2
• 申請日: 2021-05-22
• 公開（公告）號: CN113190328A
• 公開（公告）日: 2021-07-30
• 發明（設計）人: 夏元清;高潤澤;詹玉峰;翟弟華;戴荔;孫中奇;張金會;閆莉萍;劉坤;郭澤華;崔冰;鄒偉東
• 申請（專利權）人: 北京理工大學
• 主分類號: G06F9/455
• 分類號: G06F9/455;G06F8/61
• 代理公司: 北京高沃律師事務所 11569
• 代理人: 杜陽陽

1.一種面向系統辨識的容器化云工作流處理系統，其特征在于，包括：邊緣節點、鏡像倉庫、云資源池、預處理模塊、任務管理模塊、Redis數據存儲系統和Kubernetes系統；

所述邊緣節點用于采集被控對象運行產生的輸入輸出數據；

所述鏡像倉庫用于存儲多個系統辨識的工作流模板；

所述云資源池用于提供計算資源；所述計算資源包括通過所述Kubernetes系統創建的容器；

所述預處理模塊用于接收所述工作流模板和所述輸入輸出數據，根據所述工作流模板對所述輸入輸出數據進行解析，生成任務序列；

所述任務管理模塊用于接收所述任務序列，并根據所述任務序列向所述云資源池釋放任務；

Kubernetes系統用于接收所述任務序列，并根據所述任務序列創建容器；所述容器用于執行所述任務序列，獲得系統辨識結果；

所述Redis數據存儲系統用于存儲所述輸入輸出數據和所述系統辨識結果。

2.根據權利要求1所述的面向系統辨識的容器化云工作流處理系統，其特征在于，還包括監測模塊；

所述監測模塊用于從所述Kubernetes系統中實時獲取計算資源用量和任務序列的執行狀態。

3.根據權利要求2所述的面向系統辨識的容器化云工作流處理系統，其特征在于，所述任務管理模塊還用于從所述監測模塊實時接收計算資源用量和任務序列的執行狀態；根據計算資源用量、任務序列的執行狀態和所述任務序列創建容器。

4.根據權利要求2所述的面向系統辨識的容器化云工作流處理系統，其特征在于，所述監測模塊包括資源狀態跟蹤器和任務狀態跟蹤器；

所述資源狀態跟蹤器用于使用List-watch機制從所述Kubernetes系統中實時獲取計算資源用量；

所述任務狀態跟蹤器用于使用List-watch機制從所述Kubernetes系統中實時獲取任務序列的執行狀態。

5.根據權利要求1所述的面向系統辨識的容器化云工作流處理系統，其特征在于，所述預處理模塊還用于對所述任務序列進行解碼，獲得多個任務信息，將各所述任務信息寫入第一YAML文件；

所述第一YAML文件包括任務序號、任務信息在工作流中層級、任務信息與前繼任務和后續任務之間的依賴關系、任務信息對應的任務鏡像。

6.根據權利要求1所述的面向系統辨識的容器化云工作流處理系統，其特征在于，所述監測模塊還用于將計算資源用量和任務序列的執行狀態寫入第二YAML文件，并將所述第二YAML文件發送到所述Kubernetes系統。

7.根據權利要求1所述的面向系統辨識的容器化云工作流處理系統，其特征在于，每個邊緣節點中包括多個被控對象。

8.根據權利要求1所述的面向系統辨識的容器化云工作流處理系統，其特征在于，還包括用戶節點；

所述用戶節點用于接收所述系統辨識結果。

9.一種面向系統辨識的容器化云工作流處理方法，其特征在于，所述方法應用于權利要求1-8任意一項所述的面向系統辨識的容器化云工作流處理系統，所述方法包括：

制作多個系統辨識的工作流模板，并將各工作流模板的鏡像上傳到鏡像倉庫；所述工作流模板為具有前后依賴關系的有向無環圖；

采集被控對象運行產生的輸入輸出數據，將所述輸入輸出數據通過網關存儲到Redis數據存儲系統；

從所述鏡像倉庫中拉取與所述輸入輸出數據對應的工作流模板；

根據所述工作流模板對所述輸入輸出數據進行解析，生成任務序列；

通過Kubernetes系統根據所述任務序列創建容器；

根據所述任務序列向云資源池釋放任務；

通過所述容器執行所述任務序列，獲得系統辨識結果；

將所述系統辨識結果存儲到所述Redis數據存儲系統。

10.根據權利要求1所述的面向系統辨識的容器化云工作流處理方法，其特征在于，所述通過Kubernetes系統根據所述任務序列創建容器，具體包括：

從所述Kubernetes系統中實時獲取計算資源用量和任務序列的執行狀態；

根據計算資源用量、任務序列的執行狀態和所述任務序列創建容器。