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

在審

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

本發明提供了一種分布式任務調度系統及方法，可用于分布式技術領域，該系統包括：第一配置模塊，用于將金融數據分析任務分解為多個子分析任務，配置每個子分析任務的執行單元的接口信息、參數信息；其中，每個子分析任務的執行單元是通過選定的編程語言來實現的；任務發布模塊，用于將金融數據分析任務發布到待處理任務隊列；調度模塊，用于在監聽到所述待處理任務隊列有新的金融數據分析任務后，判斷所述金融數據分析任務是否立即執行，若是，根據每個子分析任務的執行單元的接口信息，獲得每個子分析任務的執行單元；執行模塊，用于并行啟動各執行單元，獲得各執行單元的執行結果。本發明可以針對金融數據分析任務實現分布式調度，執行效率高。

技術領域

本發明涉及分布式技術領域，尤其涉及一種分布式任務調度系統及方法。

背景技術

目前，金融市場業務日漸活躍，相關業務系統中涉及分析金融數據分析任務的場景越來越多。因此，需要對這些分析任務大量執行。現有技術一般是通過批量作業系統的調度，對一系列分析任務按照設定好的驅動關系調度批量作業系統中的各作業以實現數據的提取、轉換和加載過程。但是由于沒有充分考慮各分析任務的特點，并不能針對性提高分析任務的執行效率。

發明內容

本發明實施例提出一種分布式任務調度系統，用以針對金融數據分析任務實現分布式調度，執行效率高，該系統包括：

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

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

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

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

本發明實施例提出一種分布式任務調度方法，用以針對金融數據分析任務實現分布式調度，執行效率高，該方法包括：

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

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

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

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

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

本發明實施例還提供一種計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述分布式任務調度方法。

本發明實施例還提供一種計算機可讀存儲介質，所述計算機可讀存儲介質存儲有計算機程序，所述計算機程序被處理器執行時實現上述分布式任務調度方法。

本發明實施例還提供一種計算機程序產品，所述計算機程序產品包括計算機程序，所述計算機程序被處理器執行時實現上述分布式任務調度方法。