[發明專利]一種任務調度系統

在審

• 申請號: 202210549329.8
• 申請日: 2022-05-20
• 公開（公告）號: CN114816716A
• 公開（公告）日: 2022-07-29
• 發明（設計）人: 孫寧;宋娟;董航瑞;孟維宇;何賽;賈寧
• 申請（專利權）人: 北京車網科技發展有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京慧誠智道知識產權代理事務所(特殊普通合伙) 11539
• 代理人: 戴燕

1.一種任務調度系統，其特征在于，所述系統包括：基礎設施集群、資源管理器、決策引擎、云端控制器、工作流引擎、實時任務客戶端、實時任務處理引擎、離線任務客戶端和離線任務處理引擎；

所述基礎設施集群包括多個基礎設施；

所述資源管理器分別與所述基礎設施集群、所述云端控制器、所述實時任務處理引擎和所述離線任務處理引擎連接；所述資源管理器用于對所述基礎設施集群中各個所述基礎設施的資源使用狀況進行資源監控處理得到對應的實時監控數據集合；所述資源管理器還用于根據所述實時監控數據集合向所述云端控制器進行數據共享處理；所述資源管理器還用于對所述實時任務處理引擎或所述離線任務處理引擎進行基礎設施分配處理；

所述決策引擎與所述云端控制器連接；所述決策引擎用于根據輸入的車路協同數據進行任務規劃處理得到對應的規劃任務數據集合，并將攜帶了所述規劃任務數據集合的決策任務推送指令向所述云端控制器發送；所述規劃任務數據集合包括規劃任務名稱、規劃任務類型、任務資源配置清單和任務輸入數據，所述規劃任務類型包括實時任務類型和離線任務類型；

所述云端控制器與所述工作流引擎連接；所述云端控制器用于根據所述規劃任務數據集合和所述實時監控數據集合進行工作流任務數據轉換處理生成對應的工作流任務數據包，并根據所述工作流任務數據包對所述工作流引擎進行工作流任務推送處理；

所述工作流引擎分別與所述實時任務客戶端和所述離線任務客戶端連接；所述工作流引擎用于根據接收的所述工作流任務數據包進行工作流任務創建處理；所述工作流引擎還用于對工作流任務進行編輯與查詢處理；所述工作流引擎還用于對工作流任務進行分解、分發和狀態更新處理；

所述實時任務客戶端與所述實時任務處理引擎連接；所述實時任務客戶端用于將所述工作流引擎發送的當前子任務數據包向所述實時任務處理引擎轉發，并將所述實時任務處理引擎回發的子任務執行結果數據向所述工作流引擎轉發；

所述實時任務處理引擎分別與所述資源管理器和所述基礎設施集群連接；所述實時任務處理引擎用于根據所述當前子任務數據包向所述資源管理器進行設施分配申請處理得到所述基礎設施集群中對應的分配設施資源，并借助所述分配設施資源根據所述當前子任務數據包進行實時任務計算處理得到對應的子任務執行結果數據，并將所述子任務執行結果數據向所述實時任務客戶端回發；

所述離線任務客戶端與所述離線任務處理引擎連接；所述離線任務客戶端用于將所述工作流引擎發送的當前子任務數據包向所述離線任務處理引擎轉發，并將所述離線任務處理引擎回發的子任務執行結果數據向所述工作流引擎轉發；

所述離線任務處理引擎分別與所述資源管理器和所述基礎設施集群連接；所述離線任務處理引擎用于根據所述當前子任務數據包進行離線任務啟動時間查詢處理得到對應的離線任務啟動時段，并根據所述離線任務啟動時段和所述當前子任務數據包向所述資源管理器進行設施分配申請處理得到所述基礎設施集群中對應的分配設施資源，并借助所述分配設施資源根據所述當前子任務數據包進行離線任務計算處理得到對應的所述子任務執行結果數據，并將所述子任務執行結果數據向所述離線任務客戶端回發。

2.根據權利要求1所述的任務調度系統，其特征在于，

所述基礎設施至少包括交換機、計算機、服務器、數據庫；

所述基礎設施的資源至少包括CPU資源、內存資源、硬盤資源、網絡流量資源、計算接口資源。