[發(fā)明專利]一種任務(wù)調(diào)度系統(tǒng)

在審

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

本發(fā)明實施例涉及一種任務(wù)調(diào)度系統(tǒng)，所述系統(tǒng)包括：基礎(chǔ)設(shè)施集群、資源管理器、決策引擎、云端控制器、工作流引擎、實時任務(wù)客戶端、實時任務(wù)處理引擎、離線任務(wù)客戶端和離線任務(wù)處理引擎；資源管理器用于進(jìn)行資源監(jiān)控并將監(jiān)控信息向云端控制器同步；決策引擎用于進(jìn)行任務(wù)規(guī)劃并將規(guī)劃結(jié)果向云端控制器發(fā)送；云端控制器用于對工作流引擎進(jìn)行工作流任務(wù)推送；工作流引擎用于對工作流任務(wù)進(jìn)行創(chuàng)建、編輯、查詢、以及分解、分發(fā)和狀態(tài)更新處理；實時任務(wù)處理引擎用于在指定的基礎(chǔ)設(shè)施上進(jìn)行實時任務(wù)計算；離線任務(wù)處理引擎用于在離線任務(wù)啟動時段在指定的基礎(chǔ)設(shè)施上進(jìn)行離線任務(wù)計算。通過本發(fā)明系統(tǒng)能保證實時性要求較強(qiáng)的計算任務(wù)得到及時執(zhí)行。

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，特別涉及一種任務(wù)調(diào)度系統(tǒng)。

背景技術(shù)

在車聯(lián)網(wǎng)應(yīng)用中存在大量高并發(fā)的車路協(xié)同數(shù)據(jù)計算任務(wù)。常規(guī)的任務(wù)調(diào)度系統(tǒng)在處理高并發(fā)任務(wù)時都是按先到先算原則對云端用于計算的基礎(chǔ)設(shè)施的軟硬件資源進(jìn)行占用，處理過程中并未考慮任務(wù)本身的實時性特點。而車聯(lián)網(wǎng)應(yīng)用中的一些計算任務(wù)的實時性要求不強(qiáng)，但卻需要占用大量的軟硬件資源，如果仍然沿用常規(guī)任務(wù)調(diào)度系統(tǒng)的處理方式則可能會造成大量實時性要求較強(qiáng)的計算任務(wù)無法及時完成計算。

發(fā)明內(nèi)容

本發(fā)明的目的，就是針對現(xiàn)有技術(shù)的缺陷，提供一種任務(wù)調(diào)度系統(tǒng)，該系統(tǒng)包括：基礎(chǔ)設(shè)施集群、資源管理器、決策引擎、云端控制器、工作流引擎、實時任務(wù)客戶端、實時任務(wù)處理引擎、離線任務(wù)客戶端和離線任務(wù)處理引擎。本發(fā)明系統(tǒng)在進(jìn)行任務(wù)調(diào)度時充分考慮了任務(wù)的實時性特點，還為每個任務(wù)增設(shè)了優(yōu)先級屬性；通過本發(fā)明系統(tǒng)不但可以確保實時任務(wù)會被提前提取還可以基于優(yōu)先級對實時任務(wù)的提取次序進(jìn)行進(jìn)一步優(yōu)化；將本發(fā)明系統(tǒng)應(yīng)用到車輛網(wǎng)中就能保證大量實時性要求較強(qiáng)的計算任務(wù)可以得到及時執(zhí)行。

為實現(xiàn)上述目的，本發(fā)明實施例提供了一種任務(wù)調(diào)度系統(tǒng)，所述系統(tǒng)包括：基礎(chǔ)設(shè)施集群、資源管理器、決策引擎、云端控制器、工作流引擎、實時任務(wù)客戶端、實時任務(wù)處理引擎、離線任務(wù)客戶端和離線任務(wù)處理引擎；

所述基礎(chǔ)設(shè)施集群包括多個基礎(chǔ)設(shè)施；

所述資源管理器分別與所述基礎(chǔ)設(shè)施集群、所述云端控制器、所述實時任務(wù)處理引擎和所述離線任務(wù)處理引擎連接；所述資源管理器用于對所述基礎(chǔ)設(shè)施集群中各個所述基礎(chǔ)設(shè)施的資源使用狀況進(jìn)行資源監(jiān)控處理得到對應(yīng)的實時監(jiān)控數(shù)據(jù)集合；所述資源管理器還用于根據(jù)所述實時監(jiān)控數(shù)據(jù)集合向所述云端控制器進(jìn)行數(shù)據(jù)共享處理；所述資源管理器還用于對所述實時任務(wù)處理引擎或所述離線任務(wù)處理引擎進(jìn)行基礎(chǔ)設(shè)施分配處理；

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

所述云端控制器與所述工作流引擎連接；所述云端控制器用于根據(jù)所述規(guī)劃任務(wù)數(shù)據(jù)集合和所述實時監(jiān)控數(shù)據(jù)集合進(jìn)行工作流任務(wù)數(shù)據(jù)轉(zhuǎn)換處理生成對應(yīng)的工作流任務(wù)數(shù)據(jù)包，并根據(jù)所述工作流任務(wù)數(shù)據(jù)包對所述工作流引擎進(jìn)行工作流任務(wù)推送處理；

所述工作流引擎分別與所述實時任務(wù)客戶端和所述離線任務(wù)客戶端連接；所述工作流引擎用于根據(jù)接收的所述工作流任務(wù)數(shù)據(jù)包進(jìn)行工作流任務(wù)創(chuàng)建處理；所述工作流引擎還用于對工作流任務(wù)進(jìn)行編輯與查詢處理；所述工作流引擎還用于對工作流任務(wù)進(jìn)行分解、分發(fā)和狀態(tài)更新處理；

所述實時任務(wù)客戶端與所述實時任務(wù)處理引擎連接；所述實時任務(wù)客戶端用于將所述工作流引擎發(fā)送的當(dāng)前子任務(wù)數(shù)據(jù)包向所述實時任務(wù)處理引擎轉(zhuǎn)發(fā)，并將所述實時任務(wù)處理引擎回發(fā)的子任務(wù)執(zhí)行結(jié)果數(shù)據(jù)向所述工作流引擎轉(zhuǎn)發(fā)；