[發明專利]一種分布式作業調度和執行方法插件化的方法及系統

在審

• 申請號: 202011382758.8
• 申請日: 2020-12-01
• 公開（公告）號: CN114579326A
• 公開（公告）日: 2022-06-03
• 發明（設計）人: 劉慧娟;黃明;張云龍;蔡黎明;卿林鑫;姚雨薇;滕逸龍;周明
• 申請（專利權）人: 上海寶信軟件股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/48;G06F8/65
• 代理公司: 上海漢聲知識產權代理有限公司 31236
• 代理人: 胡晶

1.一種分布式作業調度和執行方法插件化的方法，其特征在于，包括：

插件配置管理步驟，提供與用戶的交互，包括：創建插件、上傳插件程序包、刪除插件、更新插件配置、更新插件程序包和查詢插件信息；

插件任務配置管理步驟，管理與用戶的交互任務，包括：創建插件任務、刪除插件任務、更新插件任務、配置插件任務的觸發規則何查詢插件任務信息；

插件版本管理步驟，管理插件的版本，一旦用戶對插件的配置進行變更，則生成新的插件版本；

插件緩存管理步驟，在各個執行節點上負責對插件程序包、插件配置進行緩存，以及對老版本插件緩存進行清理；

任務觸發執行管理步驟，按一定的調度規則或手動觸發任務執行，以及任務執行過程的管理，包括任務提交、任務啟動和任務結束；

插件任務執行步驟，在執行時引用任務配置的插件，并使用最新版本的插件運行用戶配置的任務。

2.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件配置管理步驟中，用戶通過插件配置管理步驟，創建插件并上傳插件程序包，并觸發插件版本管理步驟生成該插件的版本相關信息。

3.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件配置管理步驟中，當業務需求發生變更時，用戶通過插件配置管理步驟更新插件程序包，然后觸發插件版本管理步驟生成該插件的新版本相關信息。

4.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件任務配置管理步驟中，用戶通過插件任務配置管理步驟，創建需要基于指定插件來運行的任務，以及觸發任務運行的規則、任務運行的參數。

5.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述任務觸發執行管理步驟中，當任務觸發執行管理步驟根據用戶的觸發規則，發現用戶配置的插件任務需要執行，然后申請相應的資源，最后提交啟動任務請求，當任務是插件類型的任務時，在提交啟動任務請求時，詢問插件管理步驟，并在任務執行上下文中帶上插件目前的版本信息、該版本插件的下載地址以及該版本插件的配置信息。

6.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件任務執行步驟中，當任務是插件類型任務時，插件任務執行步驟會接收到插件任務啟動的請求，根據任務執行上下文中的插件版本等相關信息，觸發插件緩存管理步驟。

7.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件緩存管理步驟中，插件緩存管理步驟接收到緩存插件的請求之后，對比指定插件的版本，以及目前緩存的該插件的版本，如果該版本已經緩存，則直接返回；如果該版本未緩存，則根據該版本插件的下載地址去下載最新的插件，并對插件程序包進行解壓，然后將插件目前的配置信息寫入至插件緩存；最后，檢查已經緩存的插件，如果是不會再被引用的插件，那么就清理掉，完成存儲空間的釋放。

8.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述插件任務執行步驟中，在插件緩存請求返回后，引用插件緩存管理步驟緩存的插件，然后再通過插件執行當前的任務，并通知任務觸發執行管理步驟，任務完成，并附帶執行的結果以及運行日志。

9.根據權利要求1所述的分布式作業調度和執行方法插件化的方法，其特征在于，在所述任務觸發執行管理步驟中，任務觸發執行管理步驟收到任務執行完成的消息后，更新任務的狀態，并根據需要結束作業或者運行作業中后續的任務。

10.一種分布式作業調度和執行系統插件化的系統，其特征在于，包括：插件配置管理模塊、插件任務配置管理模塊、插件版本管理模塊、插件緩存管理模塊、任務觸發執行管理模塊和插件任務執行模塊；

插件配置管理模塊，提供與用戶的交互，包括：創建插件、上傳插件程序包、刪除插件、更新插件配置、更新插件程序包和查詢插件信息；

插件任務配置管理模塊，管理與用戶的交互任務，包括：創建插件任務、刪除插件任務、更新插件任務、配置插件任務的觸發規則何查詢插件任務信息；

插件版本管理模塊，管理插件的版本，一旦用戶對插件的配置進行變更，則生成新的插件版本；

插件緩存管理模塊，在各個執行節點上對插件程序包、插件配置進行緩存，以及對老版本插件緩存進行清理；

任務觸發執行管理模塊，按一定的調度規則或手動觸發任務執行，以及任務執行過程的管理，包括任務提交、任務啟動和任務結束；

插件任務執行模塊，在執行時引用任務配置的插件，并使用最新版本的插件運行用戶配置的任務。