[發(fā)明專利]分布式計算任務處理方法、裝備及電子設備

在審

• 申請?zhí)枺?/td>: 202010079531.X
• 申請日: 2020-02-04
• 公開（公告）號: CN111381948A
• 公開（公告）日: 2020-07-07
• 發(fā)明（設計）人: 王家萬
• 申請（專利權）人: 北京貝思科技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京棋拾知識產權代理事務所(普通合伙) 11863
• 代理人: 楊雪婷

本發(fā)明實施例提供了一種分布式計算任務處理方法、裝置及電子設備，其中，方法包括：獲取當前節(jié)點的處理資源狀態(tài)，所述處理資源狀態(tài)至少包括當前節(jié)點未使用的處理資源信息；根據所述當前節(jié)點的處理資源狀態(tài)向所述當前節(jié)點以外的其他節(jié)點發(fā)送任務請求；接收所述當前節(jié)點以外的其他節(jié)點對所述任務請求的響應。本發(fā)明實施例通過獲取當前節(jié)點的處理資源狀態(tài)，根據處理資源狀態(tài)發(fā)送任務請求，接收到任務請求的節(jié)點根據任務請求向發(fā)送任務請求的節(jié)點分配處理任務。從而合理調配處理任務，實現處理任務的優(yōu)化調度及資源利用率的最大化。

技術領域

本申請涉及一種分布式計算任務處理方法、裝置及電子設備，屬于 計算機技術領域。

背景技術

在現有的音視頻數據處理中，由于音視頻采集設備設置的分散 性，每個數據采集處理節(jié)點數據量不盡相同，從而導致設置在各音 視頻采集點處的視頻處理設備由于各個節(jié)點數據量不同而出現負荷 不同的情況。

發(fā)明內容

本發(fā)明實施例提供一種分布式計算任務處理方法、裝置及電子設備， 實現分散視頻采集情況下處理任務的優(yōu)化調度及資源利用率的最大化。

為了實現上述目的，本發(fā)明實施例提供了一種分布式計算任務處理 方法，包括：

獲取當前節(jié)點的處理資源狀態(tài)，所述處理資源狀態(tài)至少包括當 前節(jié)點未使用的處理資源信息；

根據所述當前節(jié)點的處理資源狀態(tài)向所述當前節(jié)點以外的其他 節(jié)點發(fā)送任務請求，其中，所述任務請求至少包含有當前節(jié)點的網 絡標識以及所述處理資源狀態(tài)；

接收所述當前節(jié)點以外的其他節(jié)點對所述任務請求的響應，其 中，所述響應中至少包含基于所述處理資源狀態(tài)的計算任務分配信 息，所述分配信息中至少包含所述計算任務的所屬節(jié)點的網絡標識 以及計算數據信息。

本發(fā)明實施例還提供了一種分布式計算任務處理方法：

接收其他節(jié)點的任務請求，所述任務請求至少包括所述發(fā)送任 務請求的節(jié)點的網絡標識以及處理資源狀態(tài)，所述處理資源狀態(tài)至 少包括發(fā)送任務請求的節(jié)點未使用的處理資源信息；

根據所述任務請求及任務狀態(tài)表，向發(fā)送任務請求的節(jié)點分配 第二任務，所述任務狀態(tài)表中至少包括當前節(jié)點未分配的任務信息；

向所述發(fā)送任務請求的節(jié)點發(fā)送所述第二任務的分配信息，所 述分配信息至少包括所述第二任務的所屬節(jié)點的網絡標識以及計算 數據信息。

本發(fā)明實施例還提供了一種分布式計算任務處理裝置，包括：

處理資源狀態(tài)獲取模塊，用于獲取當前節(jié)點的處理資源狀態(tài)， 所述處理資源狀態(tài)至少包括當前節(jié)點未使用的處理資源信息；

任務請求發(fā)送模塊，用于根據所述當前節(jié)點的處理資源狀態(tài)向 所述當前節(jié)點以外的其他節(jié)點發(fā)送任務請求，其中，所述任務請求 至少包含有當前節(jié)點的網絡標識以及所述處理資源狀態(tài)；

響應接收模塊，用于接收所述當前節(jié)點以外的其他節(jié)點對所述 任務請求的響應，其中，所述響應中至少包含基于所述處理資源狀 態(tài)的計算任務分配信息，所述分配信息中至少包含所述計算任務的 所屬節(jié)點的網絡標識以及計算數據信息。

本發(fā)明實施例還提供了一種分布式計算任務處理裝置，包括：

任務請求接收模塊，用于接收當前節(jié)點以外的其他節(jié)點的任務 請求，所述任務請求至少包括所述發(fā)送任務請求的節(jié)點的網絡標識 以及處理資源狀態(tài)，所述處理資源狀態(tài)至少包括發(fā)送任務請求的節(jié) 點未使用的處理資源信息；

任務分配模塊，用于根據所述任務請求及任務狀態(tài)表，向發(fā)送 任務請求的節(jié)點分配第二任務，所述任務狀態(tài)表中至少包括當前節(jié) 點未分配的任務信息；