[發(fā)明專利]作業(yè)調(diào)度方法、系統(tǒng)及計算設(shè)備

有效

• 申請?zhí)枺?/td>: 202010436985.8
• 申請日: 2020-05-21
• 公開（公告）號: CN111343288B
• 公開（公告）日: 2020-09-01
• 發(fā)明（設(shè)計）人: 毛登峰;楊昆;陳健
• 申請（專利權(quán)）人: 北京并行科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京思睿峰知識產(chǎn)權(quán)代理有限公司 11396
• 代理人: 謝建云;高攀

1.一種作業(yè)調(diào)度方法，在計算設(shè)備中執(zhí)行，所述計算設(shè)備與計算機集群耦接，所述計算機集群包括多個適于運行作業(yè)的計算節(jié)點，并適于基于作業(yè)運行周期運行作業(yè)，每個作業(yè)運行周期包括第一時間段、第二時間段，所述第一時間段的空閑節(jié)點數(shù)量大于第二時間段的空閑節(jié)點數(shù)量，所述方法包括步驟：

接收客戶端的作業(yè)運行請求，將所述作業(yè)添加到作業(yè)隊列，所述作業(yè)隊列中包括一個或多個作業(yè)；

確定所述作業(yè)隊列中每個作業(yè)的節(jié)點需求數(shù)量；

基于所述第一時間段的空閑節(jié)點數(shù)量區(qū)間，在當(dāng)前作業(yè)運行周期的第二時間段內(nèi)從所述作業(yè)隊列中獲取節(jié)點需求數(shù)量超過閾值的一個或多個作業(yè)作為延時作業(yè)，其中，所獲取的一個或多個作業(yè)的節(jié)點需求數(shù)量總和在所述第一時間段的空閑節(jié)點數(shù)量區(qū)間內(nèi)；以及

將所述一個或多個延時作業(yè)分配給下一個作業(yè)運行周期的第一時間段內(nèi)的多個空閑節(jié)點，以便在下一個作業(yè)運行周期的第一時間段運行所述一個或多個延時作業(yè)。

2.如權(quán)利要求1所述的作業(yè)調(diào)度方法，其中，將所述一個或多個延時作業(yè)分配給下一個作業(yè)運行周期的第一時間段內(nèi)的多個空閑節(jié)點的步驟包括：

將所述一個或多個延時作業(yè)的運行時間設(shè)置為下一個作業(yè)運行周期的第一時間段內(nèi)，以便基于所述第一時間段內(nèi)的多個空閑節(jié)點運行所述一個或多個延時作業(yè)。

3.如權(quán)利要求2所述的作業(yè)調(diào)度方法，其中，將所述一個或多個延時作業(yè)的運行時間設(shè)置為下一個作業(yè)運行周期的第一時間段內(nèi)的步驟包括：

將所述一個或多個延時作業(yè)的起始運行時間均設(shè)置為下一個作業(yè)運行周期的第一時間段的預(yù)定時間點，以便從下一個作業(yè)運行周期的所述預(yù)定時間點開始運行所述一個或多個延時作業(yè)。

4.如權(quán)利要求2所述的作業(yè)調(diào)度方法，其中，將所述一個或多個延時作業(yè)的運行時間設(shè)置為下一個作業(yè)運行周期的第一時間段內(nèi)的步驟包括：

根據(jù)所述第一時間段內(nèi)的各個時間點的空閑節(jié)點數(shù)量來確定所述一個或多個延時作業(yè)的運行時間。

5.如權(quán)利要求4所述的作業(yè)調(diào)度方法，其中，確定所述一個或多個延時作業(yè)的運行時間的步驟包括：

確定第一時間段的各個時間點的空閑節(jié)點數(shù)量，

將所述一個或多個延時作業(yè)基于節(jié)點需求數(shù)量的高低進行排序，

基于所述節(jié)點需求數(shù)量的順序、各個時間點的空閑節(jié)點數(shù)量來確定每個延時作業(yè)運行的時間點。

6.如權(quán)利要求1-5任一項所述的作業(yè)調(diào)度方法，其中，從所述作業(yè)隊列中獲取節(jié)點需求數(shù)量超過閾值的一個或多個作業(yè)的步驟包括：

在當(dāng)前作業(yè)運行周期的第二時間段內(nèi)，每隔預(yù)定時間對所述作業(yè)隊列中的作業(yè)進行掃描一次，以確定節(jié)點需求數(shù)量超過閾值的作業(yè)；

基于節(jié)點需求數(shù)量的高低、對節(jié)點需求數(shù)量超過閾值的作業(yè)進行排序，并選取節(jié)點需求數(shù)量最高的一個或多個作業(yè)，其中，所選取的一個或多個作業(yè)的節(jié)點需求數(shù)量總和在所述第一時間段的空閑節(jié)點數(shù)量區(qū)間內(nèi)。

7.如權(quán)利要求6所述的作業(yè)調(diào)度方法，其中，選取節(jié)點需求數(shù)量最高的一個或多個作業(yè)的步驟包括：

在每次掃描確定節(jié)點需求數(shù)量超過閾值的作業(yè)后，將本次確定的節(jié)點需求數(shù)量超過閾值的作業(yè)、和上一次選取的節(jié)點需求數(shù)量最高的一個或多個作業(yè)合并在一起進行排序；

從合并在一起排序的所有作業(yè)中重新選取節(jié)點需求數(shù)量最高的一個或多個作業(yè)，作為延時作業(yè)。

8.如權(quán)利要求1-5任一項所述的作業(yè)調(diào)度方法，其中，還包括步驟：

在每個作業(yè)運行周期，基于添加順序依次為所述作業(yè)隊列中的作業(yè)分配相應(yīng)的一個或多個空閑節(jié)點，以運行所述作業(yè)隊列中的作業(yè)。

9.如權(quán)利要求1-5任一項所述的作業(yè)調(diào)度方法，其中，還包括步驟：

實時監(jiān)測所述計算機集群的空閑節(jié)點數(shù)量，獲取先前一個或多個作業(yè)運行周期的空閑節(jié)點數(shù)據(jù)；

基于所述空閑節(jié)點數(shù)據(jù)確定作業(yè)運行周期的第一時間段、第二時間段，并確定所述第一時間段的空閑節(jié)點數(shù)量區(qū)間。