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

在審

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

1.一種任務執行方法，其特征在于，應用于任務調度框架，所述任務調度框架包括：主節點，所述任務執行方法包括：

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

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

2.根據權利要求1所述的方法，其特征在于，所述任務調度框架還包括：至少兩個備用節點和消息節點；

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

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

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

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

3.根據權利要求2所述的方法，其特征在于，在將所述目標備用節點晉升為主節點之后，還包括：

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

4.根據權利要求1所述的方法，其特征在于，所述任務調度框架還包括：狀態節點；

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

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

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

5.根據權利要求1所述的方法，其特征在于，所述主節點根據配置文件生成至少一個任務流節點，包括：

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

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

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

6.根據權利要求1所述的方法，其特征在于，所述任務調度框架還包括：Web節點和消息節點；

相應的，還包括：

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

所述主節點拉取所述實時任務指令，并根據所述實時任務指令執行任務。

7.一種任務執行裝置，其特征在于，應用于任務調度框架，所述任務調度框架包括：主節點，所述任務執行裝置配置在主節點中，所述任務執行裝置包括：

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

執行模塊，用于根據所述至少兩個任務和至少兩個任務之間的依賴關系依次執行所述至少兩個任務。

8.根據權利要求7所述的裝置，其特征在于，所述任務調度框架還包括：至少兩個備用節點和消息節點；

相應的，所述至少兩個備用節點，用于在所述主節點根據配置文件生成至少一個任務流節點之前，向所述消息節點發送獲取分布式鎖指令；

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

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

9.一種電子設備，其特征在于，包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序；

當所述一個或多個程序被所述一個或多個處理器執行時，使得所述處理器實現如權利要求1-6中任一所述的方法。

10.一種包含計算機程序的計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被一個或多個處理器執行時實現如權利要求1-6中任一所述的方法。