[發(fā)明專利]基于電力大數(shù)據(jù)模型任務(wù)調(diào)度方法、平臺及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011409802.X
• 申請日: 2020-12-04
• 公開（公告）號: CN112506631A
• 公開（公告）日: 2021-03-16
• 發(fā)明（設(shè)計(jì)）人: 陳聰;羅海軍;鄭鴻劍;匡啟帆;林濤
• 申請（專利權(quán)）人: 天目數(shù)據(jù)（福建）科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 廣州海心聯(lián)合專利代理事務(wù)所(普通合伙) 44295
• 代理人: 王洪娟

本發(fā)明公開了基于電力大數(shù)據(jù)模型任務(wù)調(diào)度方法、平臺及存儲介質(zhì)，本發(fā)明方法包括：基于Job管理工作類容器創(chuàng)建至少一任務(wù)模板，任務(wù)模板包括一個(gè)或多個(gè)調(diào)度任務(wù)；將任務(wù)模板部署至一個(gè)或多個(gè)微服務(wù)，形成一個(gè)或多個(gè)任務(wù)處理器；每個(gè)任務(wù)處理器對應(yīng)一個(gè)或多個(gè)任務(wù)模板的任務(wù)狀態(tài)信息和任務(wù)調(diào)度信息；每一任務(wù)處理器定時(shí)從任務(wù)控制中心同步資源狀態(tài)，根據(jù)任務(wù)處理器的任務(wù)調(diào)度信息和任務(wù)狀態(tài)信息對所述資源狀態(tài)進(jìn)行修改，將修改后的資源狀態(tài)信息返回任務(wù)控制中心，任務(wù)控制中心存儲資源狀態(tài)信息。本發(fā)明緩解了現(xiàn)有的定時(shí)任務(wù)調(diào)度方式會給調(diào)度節(jié)點(diǎn)帶來很大壓力且給系統(tǒng)的功能擴(kuò)展帶來不便的問題，還能使客戶根據(jù)自己的需求來控制調(diào)度。

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

本發(fā)明涉及電力數(shù)據(jù)處理領(lǐng)域，具體來說涉及一種基于電力大數(shù)據(jù)模型任務(wù)調(diào)度方法、平臺及存儲介質(zhì)。

背景技術(shù)

隨著電力大數(shù)據(jù)模型任務(wù)調(diào)度平臺，集群系統(tǒng)規(guī)模的擴(kuò)大以及業(yè)務(wù)流程的復(fù)雜化，集群系統(tǒng)中的定時(shí)業(yè)務(wù)數(shù)量也越來越多，按照現(xiàn)有的定時(shí)任務(wù)調(diào)度方式，會給調(diào)度節(jié)點(diǎn)帶來很大的壓力。而且，由于每增加一個(gè)實(shí)際任務(wù)，就需要在調(diào)度節(jié)點(diǎn)中配置一個(gè)調(diào)度任務(wù)，這種方式也給系統(tǒng)的功能擴(kuò)展帶來了不便。

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

為了克服現(xiàn)有技術(shù)的不足，本發(fā)明的目的在于提供基于電力大數(shù)據(jù)模型任務(wù)調(diào)度方法、平臺及存儲介質(zhì)，解決現(xiàn)有的定時(shí)任務(wù)調(diào)度方式會給調(diào)度節(jié)點(diǎn)帶來很大的壓力且給系統(tǒng)的功能擴(kuò)展帶來的不便的問題。

本發(fā)明的目的通過以下技術(shù)方案實(shí)現(xiàn)：

基于電力大數(shù)據(jù)模型任務(wù)調(diào)度方法，包括：

基于Job管理工作類容器創(chuàng)建至少一任務(wù)模板，所述任務(wù)模板包括一個(gè)或多個(gè)調(diào)度任務(wù)；將所述任務(wù)模板部署至一個(gè)或多個(gè)微服務(wù)，形成一個(gè)或多個(gè)任務(wù)處理器；每個(gè)任務(wù)處理器對應(yīng)一個(gè)或多個(gè)任務(wù)模板的任務(wù)狀態(tài)信息和任務(wù)調(diào)度信息；

每一任務(wù)處理器定時(shí)從任務(wù)控制中心同步資源狀態(tài)，并根據(jù)任務(wù)處理器的任務(wù)調(diào)度信息和任務(wù)狀態(tài)信息對所述資源狀態(tài)進(jìn)行修改，將修改后的資源狀態(tài)信息返回任務(wù)控制中心，所述任務(wù)控制中心存儲資源狀態(tài)信息。

進(jìn)一步的，一個(gè)微服務(wù)對應(yīng)一個(gè)任務(wù)處理器，一個(gè)微服務(wù)對應(yīng)一個(gè)或多個(gè)任務(wù)模板。

進(jìn)一步的，所述微服務(wù)采用Hystrix-Netflix開源的容錯(cuò)框架。

進(jìn)一步的，基于Job管理工作類容器創(chuàng)建至少一任務(wù)模板的步驟包括：

根據(jù)任務(wù)模型參數(shù)的不同生成多個(gè)Job配置文件，創(chuàng)建至少一任務(wù)模板，采用相同或不同標(biāo)簽對任務(wù)模板進(jìn)行管理,所述任務(wù)模型參數(shù)是指滿足某一電力設(shè)定規(guī)則的調(diào)度任務(wù)配置的數(shù)學(xué)模型參數(shù)。

進(jìn)一步的，對任務(wù)模板進(jìn)行管理的步驟包括：

將任務(wù)隊(duì)列設(shè)定為按照每個(gè)市級模型工作項(xiàng)目排列的隊(duì)列。

進(jìn)一步的，對任務(wù)模板進(jìn)行管理的步驟包括：

將任務(wù)隊(duì)列設(shè)定為可變?nèi)蝿?wù)數(shù)量的隊(duì)列。

進(jìn)一步的，所述調(diào)度任務(wù)包括周期任務(wù)和非周期任務(wù)。

進(jìn)一步的，對周期任務(wù)，任務(wù)調(diào)度信息包括遵循單調(diào)速率調(diào)度運(yùn)行；對非周期任務(wù)，任務(wù)調(diào)度信息包括以靜態(tài)調(diào)度方式離線完成各任務(wù)模型的任務(wù)。

進(jìn)一步的，所述容錯(cuò)框架的容錯(cuò)方法采用以下容錯(cuò)方法中的一種或多種：線程隔離、信號量隔離、降級策略和熔斷方法。

本發(fā)明的基于電力大數(shù)據(jù)模型任務(wù)調(diào)度平臺，包括：任務(wù)控制中心、一個(gè)或多個(gè)微服務(wù)模塊和Job管理工作類容器；

所述Job管理工作類容器，用于創(chuàng)建至少一任務(wù)模板，所述任務(wù)模板包括一個(gè)或多個(gè)調(diào)度任務(wù)；