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

在審

• 申請(qǐng)?zhí)枺?/td>: 202210760217.7
• 申請(qǐng)日: 2022-06-30
• 公開(kāi)（公告）號(hào): CN115174692A
• 公開(kāi)（公告）日: 2022-10-11
• 發(fā)明（設(shè)計(jì)）人: 許文郁;王廣芳;付哲;杜凱;莊坤;張立磊
• 申請(qǐng)（專利權(quán)）人: 阿里巴巴（中國(guó)）有限公司
• 主分類號(hào): H04L67/63
• 分類號(hào): H04L67/63;H04L67/1008;H04L67/1095
• 代理公司: 北京潤(rùn)澤恒知識(shí)產(chǎn)權(quán)代理有限公司 11319
• 代理人: 趙娟

本申請(qǐng)實(shí)施例提供了一種任務(wù)的調(diào)度系統(tǒng)、方法、電子設(shè)備及存儲(chǔ)介質(zhì)，調(diào)度系統(tǒng)至少包括中心云以及與中心云通信連接的若干個(gè)邊緣節(jié)點(diǎn)，每一邊緣節(jié)點(diǎn)包括若干個(gè)執(zhí)行單元；其中，中心云，用于響應(yīng)于針對(duì)目標(biāo)數(shù)據(jù)流的推流信息，獲取目標(biāo)數(shù)據(jù)流對(duì)應(yīng)的任務(wù)配置信息，并根據(jù)任務(wù)配置信息生成針對(duì)推流信息的數(shù)據(jù)處理任務(wù)；獲取各個(gè)邊緣節(jié)點(diǎn)對(duì)應(yīng)的節(jié)點(diǎn)運(yùn)行參數(shù)，并根據(jù)節(jié)點(diǎn)運(yùn)行參數(shù)從各個(gè)邊緣節(jié)點(diǎn)中選擇滿足數(shù)據(jù)處理任務(wù)對(duì)應(yīng)的第一預(yù)設(shè)條件的第一邊緣節(jié)點(diǎn)；第一邊緣節(jié)點(diǎn)，用于接收數(shù)據(jù)處理任務(wù)，并獲取各個(gè)執(zhí)行單元的單元運(yùn)行參數(shù)，并根據(jù)單元運(yùn)行參數(shù)從各個(gè)執(zhí)行單元中選擇滿足第二預(yù)設(shè)條件的第一執(zhí)行單元；第一執(zhí)行單元，用于執(zhí)行針對(duì)目標(biāo)數(shù)據(jù)流的數(shù)據(jù)處理任務(wù)。

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

本申請(qǐng)涉及邊緣計(jì)算技術(shù)領(lǐng)域，特別是涉及一種任務(wù)的調(diào)度系統(tǒng)以及一種任務(wù)的調(diào)度方法。

背景技術(shù)

視頻和圖片因其強(qiáng)大的信息承載力，已經(jīng)成為數(shù)據(jù)內(nèi)容的主要載體和信息傳播的主要方式。5G的大寬帶、低時(shí)延、廣鏈接的特性激活了云視頻監(jiān)測(cè)、云游戲、物聯(lián)網(wǎng)等場(chǎng)景應(yīng)用，從消費(fèi)互聯(lián)網(wǎng)到產(chǎn)業(yè)互聯(lián)網(wǎng)的延伸，更加促進(jìn)了終端應(yīng)用和視圖數(shù)據(jù)的爆發(fā)。其中，依托于邊緣云的基礎(chǔ)設(shè)施，通過(guò)視圖計(jì)算管控調(diào)度為視頻監(jiān)測(cè)設(shè)備提供就近的接入、音視頻處理、錄像文件轉(zhuǎn)存等功能，能夠?yàn)橛脩籼峁└叱杀緝?yōu)勢(shì)的產(chǎn)品解決方案。然而，由于流媒體處理服務(wù)部署在邊緣節(jié)點(diǎn)上，其在降低成本的同時(shí)，也將邊緣節(jié)點(diǎn)的不穩(wěn)定因素引入到數(shù)據(jù)處理的過(guò)程中，從而容易導(dǎo)致數(shù)據(jù)任務(wù)執(zhí)行過(guò)程中容易存在帶寬消耗大、成本高，以及容易由于鏈路過(guò)長(zhǎng)，導(dǎo)致網(wǎng)絡(luò)波動(dòng)嚴(yán)重，不穩(wěn)定的問(wèn)題。

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

本申請(qǐng)實(shí)施例是提供一種任務(wù)的調(diào)度系統(tǒng)以及方法，以解決或部分解決基于邊緣計(jì)算的任務(wù)執(zhí)行過(guò)程中存在帶寬消耗大、成本高以及傳輸不穩(wěn)定的問(wèn)題。

本申請(qǐng)實(shí)施例公開(kāi)了一種任務(wù)的調(diào)度系統(tǒng)，所述調(diào)度系統(tǒng)至少包括中心云以及與所述中心云通信連接的若干個(gè)邊緣節(jié)點(diǎn)，每一所述邊緣節(jié)點(diǎn)包括若干個(gè)執(zhí)行單元；其中，

所述中心云，用于響應(yīng)于針對(duì)目標(biāo)數(shù)據(jù)流的推流信息，獲取所述目標(biāo)數(shù)據(jù)流對(duì)應(yīng)的任務(wù)配置信息，并根據(jù)所述任務(wù)配置信息生成針對(duì)所述推流信息的數(shù)據(jù)處理任務(wù)；獲取各個(gè)所述邊緣節(jié)點(diǎn)對(duì)應(yīng)的節(jié)點(diǎn)運(yùn)行參數(shù)，并根據(jù)所述節(jié)點(diǎn)運(yùn)行參數(shù)從各個(gè)所述邊緣節(jié)點(diǎn)中選擇滿足所述數(shù)據(jù)處理任務(wù)對(duì)應(yīng)的第一預(yù)設(shè)條件的第一邊緣節(jié)點(diǎn)；

所述第一邊緣節(jié)點(diǎn)，用于接收所述數(shù)據(jù)處理任務(wù)，并獲取各個(gè)所述執(zhí)行單元的單元運(yùn)行參數(shù)，并根據(jù)所述單元運(yùn)行參數(shù)從各個(gè)所述執(zhí)行單元中選擇滿足第二預(yù)設(shè)條件的第一執(zhí)行單元；

所述第一執(zhí)行單元，用于執(zhí)行針對(duì)所述目標(biāo)數(shù)據(jù)流的所述數(shù)據(jù)處理任務(wù)。

可選地，所述中心云至少包括若干個(gè)服務(wù)層以及與所述服務(wù)層連接的任務(wù)管控服務(wù)；其中，

所述服務(wù)層，用于響應(yīng)于針對(duì)目標(biāo)數(shù)據(jù)流的推流信息，獲取所述目標(biāo)數(shù)據(jù)流對(duì)應(yīng)的任務(wù)配置信息，根據(jù)所述任務(wù)配置信息生成針對(duì)所述推流信息的數(shù)據(jù)處理任務(wù)；

所述任務(wù)管控服務(wù)，用于獲取各個(gè)所述邊緣節(jié)點(diǎn)對(duì)應(yīng)的節(jié)點(diǎn)運(yùn)行參數(shù)，并根據(jù)所述節(jié)點(diǎn)運(yùn)行參數(shù)從各個(gè)所述邊緣節(jié)點(diǎn)中選擇滿足所述數(shù)據(jù)處理任務(wù)對(duì)應(yīng)的第一預(yù)設(shè)條件的第一邊緣節(jié)點(diǎn)，并將所述數(shù)據(jù)處理任務(wù)下發(fā)至所述第一邊緣節(jié)點(diǎn)。

可選地，所述第一邊緣節(jié)點(diǎn)至少包括節(jié)點(diǎn)管控服務(wù)以及與所述節(jié)點(diǎn)管控服務(wù)連接的若干個(gè)執(zhí)行單元管控服務(wù)，每一所述執(zhí)行單元管控服務(wù)對(duì)應(yīng)一所述執(zhí)行單元；其中，

所述執(zhí)行單元管控服務(wù)，用于獲取所屬的執(zhí)行單元的單元運(yùn)行參數(shù)，并將所述單元運(yùn)行參數(shù)發(fā)送至所述節(jié)點(diǎn)管控服務(wù)；

所述節(jié)點(diǎn)管控服務(wù)，用于響應(yīng)于接收到所述數(shù)據(jù)處理任務(wù)，并根據(jù)各個(gè)所述執(zhí)行單元的所述單元運(yùn)行參數(shù)，從各個(gè)所述執(zhí)行單元中選擇滿足第二預(yù)設(shè)條件的第一執(zhí)行單元，并將所述數(shù)據(jù)處理任務(wù)下發(fā)至所述第一執(zhí)行單元對(duì)應(yīng)的第一執(zhí)行單元管控服務(wù)；

所述第一執(zhí)行單元，用于獲取所述第一執(zhí)行單元管控服務(wù)發(fā)送的所述目標(biāo)服務(wù)，并執(zhí)行與所述目標(biāo)數(shù)據(jù)流對(duì)應(yīng)的目標(biāo)服務(wù)。