[發明專利]一種基于數據處理的任務調度方法及相關設備

在審

• 申請號: 201910187622.2
• 申請日: 2019-03-12
• 公開（公告）號: CN110018893A
• 公開（公告）日: 2019-07-16
• 發明（設計）人: 鄧彪
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 郝傳鑫;熊永強

1.一種基于數據處理的任務調度方法，其特征在于，所述方法應用于調度服務器集群，所述方法包括：

當檢測到系統時間為目標定時任務對應的執行時間時，從存儲裝置中獲取預先存儲的各個執行服務器的負載排序結果，所述目標定時任務為預先配置的至少一個定時任務中的任一個，所述負載排序結果是按照所述各個執行服務器的負載率由小到大的順序進行排序得到，所述負載率是根據所述各個執行服務器的資源占用度信息得到；

基于所述目標定時任務的任務信息確定所述目標定時任務的任務類型；

若所述任務類型為單機任務，則根據所述負載排序結果從所述各個執行服務器中確定出排序第一的第一目標執行服務器，并將所述目標定時任務調度至所述第一目標執行服務器；

若所述任務類型為分布式任務，則確定所述目標定時任務對應的實例數量m，并根據所述負載排序結果從所述各個執行服務器中確定出排序前m的第二目標執行服務器，將所述目標定時任務調度至所述第二目標執行服務器，所述m為大于0的整數。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

按照預設時間間隔獲取各個執行服務器通過心跳信息上報的所述各個執行服務器的資源占用度信息，所述資源占用度信息包括以下至少一種：內存信息、CPU利用率和磁盤輸入/輸出速率；

根據預先配置的負載率算法和所述資源占用度信息，確定所述各個執行服務器各自對應的負載率；

按照負載率由小到大的順序對所述各個執行服務器進行排序，得到所述各個執行服務器的負載排序結果，并將所述負載排序結果存儲至存儲裝置中。

3.根據權利要求1或2所述的方法，其特征在于，所述將所述目標定時任務調度至所述第一目標執行服務器之前，所述方法還包括：

向所述第一目標執行服務器發送詢問信息；

若在預設時間內接收到所述第一目標執行服務器針對所述詢問信息的響應信息，則觸發執行所述將所述目標定時任務調度至所述第一目標執行服務器的步驟。

4.根據權利要求2所述的方法，其特征在于，所述將所述目標定時任務調度至所述第一目標執行服務器之前，所述方法還包括：

獲取所述第一目標執行服務器的資源占用度信息，并根據所述負載率算法和所述第一目標執行服務器的資源占用度信息，確定出所述第一目標執行服務器在系統時間下的負載率；

當所述在系統時間下的負載率小于預設負載率閾值時，觸發執行所述將所述目標定時任務調度至所述第一目標執行服務器的步驟。

5.根據權利要求1所述的方法，其特征在于，所述根據所述負載排序結果從所述各個執行服務器中確定出排序第一的第一目標執行服務器之后，所述方法還包括：

檢測所述第一目標執行服務器中是否運行有與所述目標定時任務相同的定時任務；

其中，所述將所述目標定時任務調度至所述第一目標執行服務器，包括：

若檢測到所述第一目標執行服務器中運行有所述與所述目標定時任務相同的定時任務，則識別所述目標定時任務對應的預設調度策略標識；

從至少一個預設調度策略中查找到所述預設調度策略標識對應的目標預設調度策略，并根據所述目標預設調度策略對所述目標定時任務進行調度。

6.根據權利要求5所述的方法，其特征在于，所述目標預設調度策略為覆蓋策略，所述根據所述目標預設調度策略對所述目標定時任務進行調度，包括：

刪除所述第一目標執行服務器中正在運行的所述與所述目標定時任務相同的定時任務，并將所述目標定時任務調度至所述第一目標執行服務器，以便于所述第一目標執行服務器執行所述目標定時任務。

7.根據權利要求5所述的方法，其特征在于，所述目標預設調度策略為排隊等待策略，所述根據所述目標預設調度策略對所述目標定時任務進行調度，包括：

檢測所述與所述目標定時任務相同的定時任務是否執行完成；

若檢測到所述與所述目標定時任務相同的定時任務執行完成，則將所述目標定時任務調度至所述第一目標執行服務器。