[發明專利]一種任務執行方法、裝置、設備及存儲介質

在審

• 申請號: 202110795214.2
• 申請日: 2021-07-14
• 公開（公告）號: CN113434279A
• 公開（公告）日: 2021-09-24
• 發明（設計）人: 蔣毓晨;羅叢建;盧肖風
• 申請（專利權）人: 上海浦東發展銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F11/14
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 趙翠香

本發明公開了一種任務執行方法、裝置、設備及存儲介質。該方法包括：所述主節點根據配置文件生成至少一個任務流節點，其中，所述任務流節點包括：至少兩個任務和至少兩個任務之間的依賴關系；所述主節點根據所述至少兩個任務和至少兩個任務之間的依賴關系依次執行所述至少兩個任務，通過本發明的技術方案，能夠將業務邏輯和任務配置解耦，降低開發和維護成本，避免因修改任務執行流程而改動業務代碼，可以自定義多任務間的執行順序和串并關系，同時支持靈活的參數配置。

技術領域

本發明實施例涉及計算機技術領域，尤其涉及一種任務執行方法、裝置、設備及存儲介質。

背景技術

現有的定時調度框架quartz不支持任務編排和流程調度，不支持定義多任務間的執行順序和串并關系，缺乏統一的任務流程編排模型，只能通過硬編碼的方式固化任務執行流程模型，任務配置和調度程序高度耦合，具有較大的開發和維護成本。此外，框架quartz雖然支持分布式模式，但是單任務只能在單個節點運行，不支持將任務分片在多節點并行執行。

發明內容

本發明實施例提供一種任務執行方法、裝置、設備及存儲介質，以實現能夠將業務邏輯和任務配置解耦，降低開發和維護成本，避免因修改任務執行流程而改動業務代碼，可以自定義多任務間的執行順序和串并關系，同時支持靈活的參數配置。

第一方面，本發明實施例提供了一種任務執行方法，應用于任務調度框架，所述任務調度框架包括：主節點，所述任務執行方法包括：

所述主節點根據配置文件生成至少一個任務流節點，其中，所述任務流節點包括：至少兩個任務和至少兩個任務之間的依賴關系；

所述主節點根據所述至少兩個任務和至少兩個任務之間的依賴關系依次執行所述至少兩個任務。

進一步的，所述任務調度框架還包括：至少兩個備用節點和消息節點；

相應的，在所述主節點根據配置文件生成至少一個任務流節點之前，還包括：

所述至少兩個備用節點向所述消息節點發送獲取分布式鎖指令；

所述消息節點根據接收到的至少兩個備用節點發送的獲取分布式鎖指令的順序從所述至少兩個備用節點中選取一個目標備用節點；

所述消息節點將所述目標備用節點晉升為主節點。

進一步的，在將所述目標備用節點晉升為主節點之后，還包括：

若所述主節點故障下線，則所述消息節點根據接收到的至少兩個備用節點發送的獲取分布式鎖指令的順序從所述至少兩個備用節點中選取一個主節點。

進一步的，所述任務調度框架還包括：狀態節點；

相應的，主節點根據所述至少兩個任務和至少兩個任務之間的依賴關系依次執行所述至少兩個任務包括：

主節點根據所述至少兩個任務和至少兩個任務之間的依賴關系依次執行所述至少兩個任務之后，得到任務流節點的執行結果；

將所述執行結果發送至所述狀態節點。

進一步的，所述主節點根據配置文件生成至少一個任務流節點，包括：

所述主節點解析配置文件得到至少兩個任務和任務之間的依賴關系；

根據所述至少兩個任務和任務之間的依賴關系生成有向圖；

若將所述有向圖輸入深度優先搜索算法，得到所述有向圖中無環路，則根據所述有向圖生成任務流節點。

進一步的，所述任務調度框架還包括：Web節點和消息節點；

相應的，還包括：

所述消息節點接收所述Web節點發送的實時任務指令；