[發明專利]分布式任務調度方法、系統、電子設備和存儲介質

在審

• 申請號: 202211247126.X
• 申請日: 2022-10-12
• 公開（公告）號: CN115629854A
• 公開（公告）日: 2023-01-20
• 發明（設計）人: 桑文鋒;曹犟;劉耀洲;付力力;余志輝
• 申請（專利權）人: 神策網絡科技（北京）有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 深圳紫藤知識產權代理有限公司 44570
• 代理人: 蘇蕾

本發明公開了一種分布式任務調度方法、系統、電子設備和存儲介質，該方法通過確定數據任務中待分配的子任務，向協調節點發送任務查詢指令，指示協調節點反饋各執行節點的任務執行信息，并根據各執行節點的任務執行信息，確定各執行節點的目標優先級，根據各執行節點的目標優先級，確定各子任務對應的目標執行節點，將各子任務分配至各子任務對應的目標執行節點進行數據處理，如此，可以實現任務的靈活分配，合理配置節點資源，通過減少處理器之間的負載不均衡的可能性，提升任務調度效果。

技術領域

本發明涉及計算機網絡技術領域，具體涉及一種分布式任務調度方法、系統、電子設備和存儲介質。

背景技術

現有的任務調度技術中，通常是單個處理器的輪詢多個任務進行處理或者并發處理多個任務，這種方式較為單一，無法利用整個集群多臺服務器的資源，且無法動態的調整處理能力，使得任務調度效果差。

發明內容

本發明實施例提供一種分布式任務調度方法、系統、電子設備和存儲介質，以提升任務調度效果。

一方面，本發明實施例提供一種分布式任務調度方法，所述方法應用在主節點，所述方法包括：

確定數據任務中待分配的子任務；

向協調節點發送任務查詢指令，所述任務查詢指令用于指示所述協調節點反饋各執行節點的任務執行信息；所述任務執行信息包括所執行任務的數量；

根據各所述執行節點的任務執行信息，確定各所述執行節點的目標優先級；

根據各所述執行節點的目標優先級，確定各所述子任務對應的目標執行節點，將各所述子任務分配至所述各所述子任務對應的目標執行節點進行數據處理。

另一方面，本發明實施例提供一種分布式任務調度方法，所述方法應用于協調節點，所述協調節點存儲有執行節點的注冊序號以及各所述執行節點的執行任務數據；所述方法包括：

接收主節點發送的任務查詢指令，根據所述任務查詢指令查詢各所述執行節點的執行任務數據，確定各所述執行節點的任務執行信息，向所述主節點反饋各執行節點的任務執行信息，以使主節點根據各所述執行節點的任務執行信息，確定各所述執行節點的目標優先級，根據各所述執行節點的目標優先級，確定各所述子任務對應的目標執行節點，將各所述子任務分配至所述各所述子任務對應的目標執行節點進行數據處理。

另一方面，本發明實施例提供一種分布式任務調度系統，所述系統包括主節點、協調節點和至少一個協調節點；

所述主節點，用于確定數據任務中待分配的子任務，向協調節點發送任務查詢指令，所述任務查詢指令用于指示所述協調節點反饋各執行節點的任務執行信息；所述任務執行信息包括所執行任務的數量；

所述協調節點，用于接收所述主節點發送的任務查詢指令，根據所述任務查詢指令查詢各所述執行節點的執行任務數據，確定各所述執行節點的任務執行信息，向所述主節點反饋各執行節點的任務執行信息；

所述主節點，用于根據各所述執行節點的任務執行信息，確定各所述執行節點的目標優先級，根據各所述執行節點的目標優先級，確定各所述子任務對應的目標執行節點，將各所述子任務分配至所述各所述子任務對應的目標執行節點進行數據處理；

所述執行節點，用于根據所述主節點分配的所述子任務進行數據處理。

另一方面，本發明實施例提供一種電子設備，包括存儲器和處理器；所述存儲器存儲有應用程序，所述處理器用于運行所述存儲器內的應用程序，以執行上述方法中的操作。

另一方面，本發明實施例提供一種存儲介質，所述存儲介質存儲有多條指令，所述指令適于處理器進行加載，以執行上述方法中的步驟。