[發明專利]任務調度方法、裝置、計算機設備和存儲介質

在審

• 申請號: 202010318663.3
• 申請日: 2020-04-21
• 公開（公告）號: CN111522641A
• 公開（公告）日: 2020-08-11
• 發明（設計）人: 李晶
• 申請（專利權）人: 北京嘀嘀無限科技發展有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京超成律師事務所 11646
• 代理人: 高玉光

1.一種任務調度方法，其特征在于，應用于任務調度系統，所述任務調度系統包括任務調度節點和多個任務處理節點，所述任務調度節點分別與每個任務處理節點通信連接；該方法包括：

任務調度節點獲取針對待分配任務的任務調度請求；所述任務調度請求中攜帶有所述待分配任務的任務標識和所述待分配任務的總量；

基于所述任務調度請求中攜帶的總量，以及所述每個任務處理節點對應的處理能力，從所述待分配任務中確定為每個任務處理節點所分配的目標任務；

將所述目標任務的任務標識發送給該目標任務所匹配的任務處理節點。

2.如權利要求1所述的方法，其特征在于，從所述待分配任務中確定為每個任務處理節點所分配的目標任務，包括：

基于各任務處理節點對應的處理能力，確定每個可用任務處理節點對應的任務分配系數；所述可用任務處理節點為任務處理節點列表中的節點地址信息對應的任務處理節點；

基于每個任務處理節點對應的任務分配系數，以及所述任務調度請求中攜帶的總量，為各個可用任務處理節點確定所分配的待分配任務的分配數量；

從所述待分配任務中，選擇所述分配數量個任務，將選擇的任務作為為該可用任務處理節點分配的目標任務。

3.如權利要求1所述的方法，其特征在于，根據以下步驟確定每個任務處理節點的處理能力：

獲取每個任務處理節點的歷史任務處理時長；

基于各個任務處理節點對應的歷史任務處理時長，確定每個任務處理節點的處理能力；或者，

獲取每個任務處理節點的空閑數據處理資源；

基于各個任務處理節點的空閑數據處理資源，確定每個任務處理節點的處理能力。

4.如權利要求3所述的方法，其特征在于，根據以下步驟更新任務處理節點列表中的節點地址信息：

獲取多個節點地址信息；

若所述多個節點地址信息中存在節點地址信息與所述任務處理節點列表中的各個節點地址信息均不匹配，則將與所述任務處理節點列表中的各個節點地址信息均不匹配的節點地址信息添加到所述任務處理節點列表中；

若所述任務處理節點列表中存在節點地址信息與獲取的各個節點地址信息均不匹配，則從所述任務處理節點列表中刪除與獲取的各個節點地址信息均不匹配的節點地址信息。

5.如權利要求1所述的方法，其特征在于，獲取針對待分配任務的任務調度請求，包括：

響應于任一任務處理節點發送的任務處理請求，獲取針對待分配任務的任務調度請求。

6.一種任務調度方法，其特征在于，該方法包括：

任務處理節點接收任務調度節點發送針對目標任務的任務處理請求；所述任務處理請求中攜帶有所述目標任務的任務標識；

基于每個所述目標任務的任務標識，以及預設的任務標識和數據表標識之間的對應關系，確定與每個目標任務對應的數據表標識；

向數據管理節點發送數據查詢請求；所述數據查詢請求中攜帶有與每個目標任務對應數據表標識；

接收并處理所述數據管理節點返回的與每個目標任務對應的數據表。

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

數據管理節點接收任務處理節點發送的數據查詢請求；所述數據查詢請求中攜帶有目標任務分別對應的數據表標識；

在數據表標識和數據表之間的對應關系中，查詢與所述數據表標識對應的數據表；

將查詢到的數據表發送給所述任務處理節點。