[發明專利]分布式任務調度系統及方法

在審

• 申請號: 202210310344.7
• 申請日: 2022-03-28
• 公開（公告）號: CN114637589A
• 公開（公告）日: 2022-06-17
• 發明（設計）人: 廖濤;于海超;孫亮;王艷君
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/448
• 代理公司: 北京三友知識產權代理有限公司 11127
• 代理人: 郝博;湯在彥

1.一種分布式任務調度系統，其特征在于，包括：

第一配置模塊，用于將金融數據分析任務分解為多個子分析任務，配置每個子分析任務的執行單元的接口信息、參數信息；其中，每個子分析任務的執行單元是通過選定的編程語言來實現的，所述編程語言滿足所述子分析任務的計算需求；

任務發布模塊，用于將金融數據分析任務發布到待處理任務隊列；

調度模塊，用于在監聽到所述待處理任務隊列有新的金融數據分析任務后，根據當前系統資源判斷所述金融數據分析任務是否立即執行，若是，根據每個子分析任務的執行單元的接口信息，查詢服務注冊中心，獲得每個子分析任務的執行單元；

執行模塊，用于基于執行單元的參數信息，并行啟動各執行單元，獲得各執行單元的執行結果；根據各執行單元的執行結果分析金融數據分析任務的執行結果。

2.如權利要求1所述的系統，其特征在于，調度模塊還用于：

在根據當前系統資源判斷所述金融數據分析任務不立即執行時，間隔設定時長后，根據當前系統資源判斷所述金融數據分析任務是否立即執行。

3.如權利要求2所述的系統，其特征在于，執行模塊具體用于：

將具有關聯關系的子分析任務添加至一個執行組；

并行執行多個執行組。

4.如權利要求1所述的系統，其特征在于，執行模塊具體用于：

在并行啟動各執行單元之前，生成執行記錄；

在并行啟動各執行單元后，將各執行單元的執行結果更新至所述執行記錄；

基于所述執行記錄，分析金融數據分析任務的執行結果。

5.如權利要求1所述的系統，其特征在于，每個子分析任務的執行單元有多個。

6.如權利要求1所述的系統，其特征在于，還包括監控模塊，用于：

監控執行單元的執行狀況；

在執行單元執行子分析任務失敗時，確定所述執行單元對應的子分析任務的后置關聯子分析任務；

停止所述后置關聯子分析任務。

7.一種分布式任務調度方法，其特征在于，包括：

將金融數據分析任務分解為多個子分析任務，配置每個子分析任務的執行單元的接口信息、參數信息；其中，每個子分析任務的執行單元是通過選定的編程語言來實現的，所述編程語言滿足所述子分析任務的計算需求；

將金融數據分析任務發布到待處理任務隊列；

在監聽到所述待處理任務隊列有新的金融數據分析任務后，根據當前系統資源判斷所述金融數據分析任務是否立即執行，若是，根據每個子分析任務的執行單元的接口信息，查詢服務注冊中心，獲得每個子分析任務的執行單元；

基于執行單元的參數信息，并行啟動各執行單元，獲得各執行單元的執行結果；

根據各執行單元的執行結果分析金融數據分析任務的執行結果。

8.一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現權利要求7所述方法。

9.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現權利要求7所述方法。

10.一種計算機程序產品，其特征在于，所述計算機程序產品包括計算機程序，所述計算機程序被處理器執行時實現權利要求7所述方法。