[發明專利]一種分布式任務調度方法、裝置、計算機設備及存儲介質

在審

• 申請號: 202011621605.4
• 申請日: 2020-12-30
• 公開（公告）號: CN112650572A
• 公開（公告）日: 2021-04-13
• 發明（設計）人: 劉耀暉
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F16/27
• 代理公司: 深圳眾鼎專利商標代理事務所(普通合伙) 44325
• 代理人: 譚果林

1.一種分布式任務調度方法，其特征在于，包括：

以預設頻率輪詢數據庫中的任務信息表，獲得各調度任務的調度任務信息；

根據所述調度任務信息確定所述調度任務的任務類型；

若所述任務類型為秒級任務，則根據所述秒級任務的調度任務信息生成秒級任務實例，所述秒級任務為需要即時執行的任務；

確定執行所述秒級任務實例的秒級任務執行器，并將所述秒級任務實例發送至所述秒級任務執行器，以使所述秒級任務執行器執行所述秒級任務實例；

接收所述秒級任務執行器反饋的秒級任務執行信息，并根據所述秒級任務執行信息更新所述任務信息表。

2.如權利要求1所述的分布式任務調度方法，其特征在于，所述根據所述調度任務信息確定所述調度任務的任務類型之后，所述方法還包括：

若所述任務類型為定時任務，則根據所述定時任務的調度任務信息生成定時任務實例，所述定時任務為需要以一定的時長間隔執行的任務，所述定時任務實例包括所述定時任務的下次執行時刻；

確定所述下次執行時刻是否在所述預設時刻之后；

若所述下次執行時刻在所述預設時刻之后，則將所述定時任務實例置入時間輪；

當所述時間輪的計時時刻達到所述下次執行時刻時，確定是否需要執行所述定時任務實例；

若需要執行所述定時任務實例，則確定執行所述定時任務實例的定時任務執行器，并將所述定時任務實例發送至定時任務執行器，以使所述定時任務執行器執行所述定時任務實例；

接收所述定時任務執行器反饋的定時任務執行信息，并根據所述定時任務執行信息更新所述任務信息表。

3.如權利要求2所述的分布式任務調度方法，其特征在于，所述確定是否需要執行所述定時任務實例，包括：

確定所述定時任務實例中的任務狀態是否為啟用狀態；

若所述定時任務實例中的任務狀態為所述啟用狀態，則確定為需要執行所述定時任務實例；

若所述定時任務實例中的任務狀態為非啟用狀態，確定為不需要執行所述定時任務實例。

4.如權利要求1所述的分布式任務調度方法，其特征在于，所述根據所述秒級任務的調度任務信息生成秒級任務實例，包括：

在所述調度任務信息中確定所述秒級任務的任務狀態和任務ID；

確定所述任務狀態是否為啟用狀態；

若所述任務狀態為所述啟用狀態，則根據所述任務ID查詢任務日志記錄表，以確定所述秒級任務是否需要進行調度，所述任務日志記錄表中保存有所述調度任務的任務實例日志信息；

若確定所述秒級任務需要進行調度，則根據所述秒級任務的調度任務信息生成所述秒級任務實例，并更新所述任務日志記錄表。

5.如權利要求1-4任一項所述的分布式任務調度方法，其特征在于，所述確定執行所述秒級任務實例的秒級任務執行器，包括：

確定所述秒級任務實例中是否配置有執行所述秒級任務實例的配置執行器；

若所述秒級任務實例中配置有執行所述秒級任務實例的配置執行器，則確定當前所有的可用任務執行器，并確定所述配置執行器是否為所述可用任務執行器；

若所述配置執行器為所述可用任務執行器，則將所述配置執行器作為所述秒級任務執行器；

若所述秒級任務實例中未配置有執行所述秒級任務實例的配置執行器，或所述配置執行器不為所述可用任務執行器，則在當前所有的所述可用任務執行器中確定所述秒級任務執行器。

6.如權利要求5所述的分布式任務調度方法，其特征在于，所述在當前所有的所述可用任務執行器中確定所述秒級任務執行器，包括：

獲取所述可用任務執行器實時的執行器信息，所述執行器信息包括所述可用任務執行器的CPU、內存和磁盤空間；

根據所述可用任務執行器的CPU、內存和磁盤空間對所述可用任務執行器進行評估，以獲得所有所述可用任務執行器的健康評分；

選取所述健康評分最高的可用任務執行器作為所述秒級任務執行器。