[發明專利]一種任務調度方法、裝置、系統及電子設備

有效

• 申請號: 201710475515.0
• 申請日: 2017-06-21
• 公開（公告）號: CN109101325B
• 公開（公告）日: 2020-12-18
• 發明（設計）人: 謝忠賢;浦世亮;周明耀;宣云飛
• 申請（專利權）人: 杭州海康威視數字技術股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京柏杉松知識產權代理事務所(普通合伙) 11413
• 代理人: 孫翠賢;項京

1.一種任務調度方法，其特征在于，所述方法包括：

接收任務請求；

獲得目標計算節點的空閑任務數量，所述目標計算節點為發出所述任務請求的計算節點；

根據當前所述目標計算節點分別從各服務器下載數據的下載速度以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項，其中，所述屬性信息至少包括任務項所在服務器的標識；

將所確定的目標任務項分配給所述目標計算節點，以使得所述目標計算節點根據各目標任務項的屬性信息，分別從對應的服務器中下載目標數據，所述目標數據為所述目標任務項對應的存儲于服務器的數據；

其中，所述根據當前所述目標計算節點分別從各服務器下載數據的下載速度以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項的步驟，包括：

根據當前的配置對照表以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項；所述配置對照表為：根據各計算節點分別從各服務器下載數據的下載速度所更新獲得的。

2.根據權利要求1所述的方法，其特征在于，根據各計算節點分別從各服務器下載數據的下載速度更新所述配置對照表的方式，包括：

獲得并記錄各個計算節點分別從各個服務器中下載數據時對應的下載速度；

判斷是否達到預設的配置對照表更新條件；

如果是，根據所記錄的下載速度，更新所述配置對照表。

3.根據權利要求2所述的方法，其特征在于，所述判斷是否達到預設的配置對照表更新條件，包括：

判斷是否達到預設時間點；和/或，

判斷第一時間段內下載完成的任務項的數據總量是否大于預設數據總量，其中，所述第一時間段為：上一次更新配置對照表至當前時刻的時間段；和/或，

判斷所述第一時間段內下載完成的任務項的數量總和是否大于預設數量。

4.根據權利要求1所述的方法，其特征在于，所述根據當前所述目標計算節點分別從各服務器下載數據的下載速度以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項的步驟，包括：

判斷當前任務隊列中是否存在第一任務項，所述第一任務項為等待時長不小于預設限值的任務項；

如果存在，判斷所述第一任務項的數量是否不小于所述空閑任務數量，如果是，從所述第一任務項中確定所述空閑任務數量個目標任務項；如果否，將所述第一任務項均確定為第一目標任務項，從當前任務隊列中除所述第一任務項外的任務項中確定第一數量個第二目標任務項，將所述第一目標任務項和所述第二目標任務項確定為目標任務項，其中，所述第一數量等于所述空閑任務數量與所述第一任務項的數量的差值；

如果不存在，利用當前所述目標計算節點分別從各服務器下載數據的下載速度以及當前任務隊列中各任務項的屬性信息，得到與所述目標節點匹配的所述空閑任務數量個目標任務項。

5.根據權利要求1-4中任一項所述的方法，其特征在于，在接收任務請求之后，所述方法還包括：

拒絕接收其他計算節點發出的任務請求。

6.一種任務調度裝置，其特征在于，所述裝置包括：

接收模塊，用于接收任務請求；

獲得模塊，用于獲得目標計算節點的空閑任務數量，所述目標計算節點為發出所述任務請求的計算節點；

確定模塊，用于根據當前所述目標計算節點分別從各服務器下載數據的下載速度以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項，其中，所述屬性信息至少包括任務項所在服務器的標識；

分配模塊，用于將所確定的目標任務項分配給所述目標計算節點，以使得所述目標計算節點根據各目標任務項的屬性信息，分別從對應的服務器中下載目標數據，所述目標數據為所述目標任務項對應的存儲于服務器的數據；

其中，所述確定模塊，具體用于：

根據當前的配置對照表以及當前任務隊列中各任務項的屬性信息，確定與所述目標節點匹配的所述空閑任務數量個目標任務項；所述配置對照表為：根據各計算節點分別從各服務器下載數據的下載速度所更新獲得的。