[發(fā)明專利]任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110704187.3
• 申請(qǐng)日: 2021-06-24
• 公開（公告）號(hào): CN113407174A
• 公開（公告）日: 2021-09-17
• 發(fā)明（設(shè)計(jì)）人: 徐道帆;陳華佳;田力;李羽
• 申請(qǐng)（專利權(quán)）人: 微民保險(xiǎn)代理有限公司
• 主分類號(hào): G06F8/34
• 分類號(hào): G06F8/34;G06F8/71;G06F9/48
• 代理公司: 深圳智匯遠(yuǎn)見知識(shí)產(chǎn)權(quán)代理有限公司 44481
• 代理人: 王旭

本申請(qǐng)涉及一種任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)，該方法包括，從可視化配置界面的關(guān)系圖編輯區(qū)域，獲取用于反映各任務(wù)之間的依賴關(guān)系的關(guān)系圖；解析關(guān)系圖，生成與任務(wù)調(diào)度系統(tǒng)適配的配置文件；當(dāng)將配置文件上傳至任務(wù)調(diào)度系統(tǒng)后，從可視化配置界面的調(diào)度信息配置區(qū)域，獲取各任務(wù)的調(diào)度信息；向任務(wù)調(diào)度系統(tǒng)發(fā)送調(diào)度信息，以使得任務(wù)調(diào)度系統(tǒng)基于配置文件和調(diào)度信息執(zhí)行對(duì)各任務(wù)的任務(wù)調(diào)度。可視化配置界面的關(guān)系圖編輯區(qū)域和調(diào)度信息配置區(qū)域?qū)崿F(xiàn)了在一次配置過程中對(duì)調(diào)度信息和用于解析得到配置文件的依賴關(guān)系的配置，因此配置過程簡單。

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

本申請(qǐng)涉及計(jì)算機(jī)領(lǐng)域，尤其涉及一種任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

Azkaban作為工作流調(diào)度工具，集調(diào)度、編排、失敗重試、郵件告警等功能為一體。當(dāng)前應(yīng)用時(shí)，用戶手動(dòng)編寫完成各任務(wù)各自的配置文件，并將所有的配置文件及所需要的資源文件打包成一個(gè)zip文件，通過Azkaban服務(wù)器提供的用戶界面向Azkaban服務(wù)器上傳zip文件，之后再通過該用戶界面調(diào)取Azkaban服務(wù)器上各任務(wù)各自的調(diào)度信息配置頁面，通過頁面切換的方式，逐一完成各調(diào)度信息配置頁面上調(diào)度信息的配置。

然而，由于配置文件的編寫和調(diào)度信息的配置由用戶分多次完成，因此導(dǎo)致配置過程較復(fù)雜。

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

本申請(qǐng)?zhí)峁┝艘环N任務(wù)調(diào)度方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)，用以解決相關(guān)技術(shù)中配置過程較復(fù)雜問題。

第一方面.提供一種任務(wù)調(diào)度方法，包括：

從可視化配置界面的關(guān)系圖編輯區(qū)域，獲取用于反映各任務(wù)之間的依賴關(guān)系的關(guān)系圖；

解析所述關(guān)系圖，生成與任務(wù)調(diào)度系統(tǒng)適配的配置文件；

當(dāng)將所述配置文件上傳至所述任務(wù)調(diào)度系統(tǒng)后，從所述可視化配置界面的調(diào)度信息配置區(qū)域，獲取所述各任務(wù)的調(diào)度信息，所述調(diào)度信息包括各任務(wù)所屬項(xiàng)目的執(zhí)行時(shí)間和告警信息；

向所述任務(wù)調(diào)度系統(tǒng)發(fā)送所述調(diào)度信息，以使得所述任務(wù)調(diào)度系統(tǒng)基于所述配置文件和所述調(diào)度信息執(zhí)行對(duì)所述各任務(wù)的任務(wù)調(diào)度。

可選地，解析所述關(guān)系圖，生成與任務(wù)調(diào)度系統(tǒng)適配的配置文件，包括：

按照預(yù)設(shè)的計(jì)算機(jī)語言格式，生成與所述關(guān)系圖對(duì)應(yīng)的關(guān)系圖描述，所述關(guān)系圖描述包括用于指示各結(jié)點(diǎn)的結(jié)點(diǎn)信息的第一部分描述和用于指示所述各結(jié)點(diǎn)的結(jié)點(diǎn)關(guān)系的第二部分描述，任意一個(gè)任務(wù)在所述關(guān)系圖中具有唯一對(duì)應(yīng)的結(jié)點(diǎn)；

從所述第一部分描述中分別獲取各結(jié)點(diǎn)各自的結(jié)點(diǎn)信息、以及從所述第二部分描述中分別獲取所述各結(jié)點(diǎn)各自的依賴結(jié)點(diǎn)；

根據(jù)所述各結(jié)點(diǎn)各自的結(jié)點(diǎn)信息和所述各結(jié)點(diǎn)各自的依賴結(jié)點(diǎn)，生成與所述任務(wù)調(diào)度系統(tǒng)適配的所述配置文件。

可選地，按照預(yù)設(shè)的計(jì)算機(jī)語言格式，生成與所述關(guān)系圖對(duì)應(yīng)的關(guān)系圖描述，包括：

按照預(yù)先設(shè)置的結(jié)點(diǎn)屬性，識(shí)別所述關(guān)系圖中的至少一個(gè)結(jié)點(diǎn)；

分別獲取所述各結(jié)點(diǎn)各自的結(jié)點(diǎn)信息；

分別識(shí)別與所述各結(jié)點(diǎn)各自具有連接關(guān)系的有向線段；

基于所述有向線段的方向，分別確定所述各結(jié)點(diǎn)各自的依賴結(jié)點(diǎn)；

按照所述預(yù)設(shè)的計(jì)算機(jī)語言格式，描述所述各結(jié)點(diǎn)各自的結(jié)點(diǎn)信息和所述各結(jié)點(diǎn)各自的依賴結(jié)點(diǎn)，得到所述關(guān)系圖描述。

可選地，從所述第二部分描述中分別獲取所述各結(jié)點(diǎn)各自的依賴結(jié)點(diǎn)，包括：

對(duì)于任意一個(gè)結(jié)點(diǎn)，從所述第二部分描述中查找目標(biāo)結(jié)點(diǎn)為所述結(jié)點(diǎn)的目標(biāo)結(jié)點(diǎn)關(guān)系；

獲取所述目標(biāo)結(jié)點(diǎn)關(guān)系中的起始結(jié)點(diǎn)；