[發明專利]一種任務調度方法、系統、設備及存儲介質

在審

• 申請號: 202110609946.8
• 申請日: 2021-06-01
• 公開（公告）號: CN113157426A
• 公開（公告）日: 2021-07-23
• 發明（設計）人: 陳新浩;張飛;余智平
• 申請（專利權）人: 微醫云（杭州）控股有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種任務調度方法，應用于任務調度系統，其特征在于，包括：

獲取業務方發送的定時任務的觸發請求；

基于至少一個單元的主節點并行調度所述觸發請求對應的定時任務，其中，每個所述單元包括一個主節點和至少一個從節點，每個所述單元由至少兩個服務器中的唯一節點構成；

基于所述至少一個單元的主節點對應的定時任務的執行信息，生成至少一個任務執行日志。

2.根據權利要求1所述的方法，在所述獲取業務方發送的定時任務的觸發請求之前，所述方法還包括：

創建至少一個定時任務和所述定時任務的調度條件，所述調度條件至少包括定時觸發條件、調度類型、調度參數以及調度地址；

設置創建完成的至少一個定時任務的開啟狀態。

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

獲取所述定時任務的任務查詢請求和/或任務變更請求，其中，所述任務變更請求包括任務修改請求、任務刪除請求、任務增加請求、任務狀態啟動請求、任務狀態停止請求以及手動執行任務請求中的至少一種；

基于所述任務查詢請求查詢所述對應的任務執行日志，和/或，基于所述任務變更請求，修改至少一個單元對應的定時任務，并將查詢到的任務執行日志和/或修改后的定時任務發送至前端頁面。

4.根據權利要求1所述的方法，其特征在于，所述基于至少一個單元的主節點并行調度所述觸發請求對應的定時任務，包括：

通過任務獲取線程，查找各單元的主節點對應的定時任務，將所述各單元的主節點對應的定時任務加入內存中的隊列內；

通過任務調度線程，提取所述內存中的隊列的所述各單元的主節點對應的定時任務，將提取的所述各單元的主節點對應的定時任務傳遞至任務執行線程；

通過所述任務執行線程調用遠程調用線程，以觸發業務方接口，以使所述業務方根據所述業務方接口的觸發信息執行對應的定時任務。

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

通過各所述單元的主節點統計對應的任務執行日志的數量；

如果任一單元的主節點的定時任務為待運行狀態，或者，正在運行的任一單元的主節點的定時任務在設定時間內的任務執行日志的數量為0，通過該單元的主節點重置對應的定時任務的執行狀態。

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

通過各所述單元的主節點獲取數據庫中定時任務的執行信息，并根據對應的定時任務的執行信息，對內存中定時任務的執行信息進行檢查。

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

確定每個單元的定時任務的執行頻率；

將執行頻率大于或等于設定頻率的定時任務確定為內存任務，將執行頻率小于設定頻率的定時任務確定為數據庫任務。

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

根據所述任務執行日志確定執行失敗的定時任務的異常信息。

9.根據權利要求1所述的方法，其特征在于，所述方法還包括下述至少一項：

定時統計各團隊的定時任務量，基于各團隊的定時任務量確定所有團隊的定時任務總量，并將各業務方的所有團隊的定時任務總量發送至對應的業務方；

根據接收到的任一團隊的修改請求修改團隊信息，并根據接收到的任一團隊的關注請求，確定該團隊的團隊信息，并將所述團隊信息發送至對應業務方的對應團隊。

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

基于預先確定的配置文件創建節點構建者，對各單元的節點進行檢查，以及確定重啟問題節點。

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

根據預先確定的配置文件創建節點，并確定每個節點的單元名稱和節點名，以及開啟各節點的線程。