[發(fā)明專利]任務(wù)調(diào)度方法、裝置、計算機設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010318663.3
• 申請日: 2020-04-21
• 公開（公告）號: CN111522641A
• 公開（公告）日: 2020-08-11
• 發(fā)明（設(shè)計）人: 李晶
• 申請（專利權(quán)）人: 北京嘀嘀無限科技發(fā)展有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京超成律師事務(wù)所 11646
• 代理人: 高玉光

本公開提供了一種任務(wù)調(diào)度方法、裝置、計算機設(shè)備和存儲介質(zhì)，應(yīng)用于任務(wù)調(diào)度系統(tǒng)，所述任務(wù)調(diào)度系統(tǒng)包括任務(wù)調(diào)度節(jié)點和多個任務(wù)處理節(jié)點，所述任務(wù)調(diào)度節(jié)點分別與每個任務(wù)處理節(jié)點通信連接；該方法包括：任務(wù)調(diào)度節(jié)點獲取針對待分配任務(wù)的任務(wù)調(diào)度請求；所述任務(wù)調(diào)度請求中攜帶有所述待分配任務(wù)的任務(wù)標識和所述待分配任務(wù)的總量；基于所述任務(wù)調(diào)度請求中攜帶的總量，以及所述每個任務(wù)處理節(jié)點對應(yīng)的處理能力，從所述待分配任務(wù)中確定為每個任務(wù)處理節(jié)點所分配的目標任務(wù)；將所述目標任務(wù)的任務(wù)標識發(fā)送給該目標任務(wù)所匹配的任務(wù)處理節(jié)點。本公開能夠提高任務(wù)的處理效率。

技術(shù)領(lǐng)域

本公開涉及通信處理技術(shù)領(lǐng)域，具體而言，涉及一種任務(wù)調(diào)度方法、裝置、計算機設(shè)備和存儲介質(zhì)。

背景技術(shù)

在傳統(tǒng)的業(yè)務(wù)系統(tǒng)中，當(dāng)用戶量不大、數(shù)據(jù)量不多時，任務(wù)處理系統(tǒng)可以采用單機進行任務(wù)處理，處理任務(wù)需要的數(shù)據(jù)采用單表存儲，數(shù)據(jù)可以存放在數(shù)據(jù)庫中。

當(dāng)需要批量處理某一表里面的數(shù)據(jù)，調(diào)度系統(tǒng)在固定時間點向任務(wù)處理設(shè)備發(fā)起單個任務(wù)，任務(wù)處理系統(tǒng)接收到任務(wù)處理指令，從數(shù)據(jù)庫中循環(huán)撈取對應(yīng)的數(shù)據(jù)，并對撈取到的數(shù)據(jù)進行處理。當(dāng)任務(wù)量越來越多時，任務(wù)在任務(wù)處理設(shè)備中排隊進行處理，處理任務(wù)所消耗的時間會越來越長，降低任務(wù)處理效率。

發(fā)明內(nèi)容

本公開實施例至少提供一種任務(wù)調(diào)度方法、裝置、計算機設(shè)備和存儲介質(zhì)，提高任務(wù)的處理效率。

第一方面，本公開實施例提供了一種任務(wù)調(diào)度方法，應(yīng)用于任務(wù)調(diào)度系統(tǒng)，所述任務(wù)調(diào)度系統(tǒng)包括任務(wù)調(diào)度節(jié)點和多個任務(wù)處理節(jié)點，所述任務(wù)調(diào)度節(jié)點分別與每個任務(wù)處理節(jié)點通信連接；該方法包括：

任務(wù)調(diào)度節(jié)點獲取針對待分配任務(wù)的任務(wù)調(diào)度請求；所述任務(wù)調(diào)度請求中攜帶有所述待分配任務(wù)的任務(wù)標識和所述待分配任務(wù)的總量；

基于所述任務(wù)調(diào)度請求中攜帶的總量，以及所述每個任務(wù)處理節(jié)點對應(yīng)的處理能力，從所述待分配任務(wù)中確定為每個任務(wù)處理節(jié)點所分配的目標任務(wù)；

將所述目標任務(wù)的任務(wù)標識發(fā)送給該目標任務(wù)所匹配的任務(wù)處理節(jié)點。

在一種實施方式中，從所述待分配任務(wù)中確定為每個任務(wù)處理節(jié)點所分配的目標任務(wù)，包括：

基于各任務(wù)處理節(jié)點對應(yīng)的處理能力，確定每個任務(wù)處理節(jié)點對應(yīng)的任務(wù)分配系數(shù)；

基于每個任務(wù)處理節(jié)點對應(yīng)的任務(wù)分配系數(shù)，以及所述任務(wù)調(diào)度請求中攜帶的總量，為各個可用任務(wù)處理節(jié)點確定所分配的待分配任務(wù)的分配數(shù)量；所述可用任務(wù)處理節(jié)點為任務(wù)處理節(jié)點列表中的節(jié)點地址信息對應(yīng)的任務(wù)處理節(jié)點；

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

在一種實施方式中，根據(jù)以下步驟確定每個任務(wù)處理節(jié)點的處理能力：

獲取每個任務(wù)處理節(jié)點的歷史任務(wù)處理時長；

基于各個任務(wù)處理節(jié)點對應(yīng)的歷史任務(wù)處理時長，確定每個任務(wù)處理節(jié)點的處理能力；或者，

獲取每個任務(wù)處理節(jié)點的空閑數(shù)據(jù)處理資源；

基于各個任務(wù)處理節(jié)點的空閑數(shù)據(jù)處理資源，確定每個任務(wù)處理節(jié)點的處理能力。

在一種實施方式中，根據(jù)以下步驟更新任務(wù)處理節(jié)點列表中的節(jié)點地址信息：

獲取多個節(jié)點地址信息；

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