[發(fā)明專利]分布式任務(wù)調(diào)度的方法、任務(wù)調(diào)度平臺(tái)及任務(wù)執(zhí)行器

在審

• 申請(qǐng)?zhí)枺?/td>: 202011623937.6
• 申請(qǐng)日: 2020-12-31
• 公開(kāi)（公告）號(hào): CN112685184A
• 公開(kāi)（公告）日: 2021-04-20
• 發(fā)明（設(shè)計(jì)）人: 吳曉富
• 申請(qǐng)（專利權(quán)）人: 廣州極飛科技有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50
• 代理公司: 北京潤(rùn)平知識(shí)產(chǎn)權(quán)代理有限公司 11283
• 代理人: 陳瀟瀟

1.一種分布式任務(wù)調(diào)度的方法，應(yīng)用于任務(wù)調(diào)度平臺(tái)，其特征在于，所述任務(wù)調(diào)度平臺(tái)與任務(wù)執(zhí)行器通信，所述任務(wù)執(zhí)行器設(shè)置于云服務(wù)器和/或邊緣設(shè)備中，所述方法包括：

接收所述任務(wù)執(zhí)行器發(fā)送的心跳注冊(cè)請(qǐng)求，所述心跳注冊(cè)請(qǐng)求包括所述任務(wù)執(zhí)行器的狀態(tài)信息；

響應(yīng)于接收到所述心跳注冊(cè)請(qǐng)求，生成所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)信箱；

根據(jù)所述任務(wù)執(zhí)行器的狀態(tài)信息將任務(wù)池中的任務(wù)派發(fā)至所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)信箱。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述任務(wù)執(zhí)行器的狀態(tài)信息包括以下至少一項(xiàng)：所述任務(wù)執(zhí)行器的通用唯一識(shí)別碼、所述任務(wù)執(zhí)行器的節(jié)點(diǎn)狀態(tài)；

根據(jù)所述任務(wù)執(zhí)行器的狀態(tài)信息將任務(wù)池中的任務(wù)派發(fā)至所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)信箱，包括：

獲取任務(wù)池中的每一任務(wù)對(duì)應(yīng)的通用唯一識(shí)別碼，以確定每一任務(wù)對(duì)應(yīng)的任務(wù)執(zhí)行器；

根據(jù)所述通用唯一識(shí)別碼確定每一任務(wù)對(duì)應(yīng)任務(wù)信箱，并將每一任務(wù)派發(fā)至對(duì)應(yīng)的任務(wù)信箱。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

獲取所述任務(wù)執(zhí)行器固定間隔時(shí)間段發(fā)送的任務(wù)獲取請(qǐng)求；

根據(jù)所述任務(wù)獲取請(qǐng)求從對(duì)應(yīng)的任務(wù)信箱取出一個(gè)任務(wù)信息返回所述任務(wù)執(zhí)行器。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述任務(wù)獲取請(qǐng)求中包括對(duì)應(yīng)的任務(wù)執(zhí)行器的唯一識(shí)別碼；

所述根據(jù)所述任務(wù)獲取請(qǐng)求從對(duì)應(yīng)的任務(wù)信箱取出一個(gè)任務(wù)返回所述任務(wù)執(zhí)行器，包括：

根據(jù)所述任務(wù)獲取請(qǐng)求中的唯一識(shí)別碼確定所述任務(wù)獲取請(qǐng)求對(duì)應(yīng)的目標(biāo)任務(wù)執(zhí)行器和目標(biāo)任務(wù)信箱；

從所述目標(biāo)任務(wù)信箱中獲取對(duì)應(yīng)的任務(wù)信息，并將所述任務(wù)信息發(fā)送至所述目標(biāo)任務(wù)執(zhí)行器。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

獲取所述任務(wù)執(zhí)行器發(fā)送的任務(wù)處理信息，所述任務(wù)處理信息包括所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)處理進(jìn)度信息；

將所述任務(wù)處理信息存儲(chǔ)于數(shù)據(jù)庫(kù)。

6.一種分布式任務(wù)調(diào)度的方法，應(yīng)用于任務(wù)執(zhí)行器，其特征在于，所述任務(wù)執(zhí)行器與任務(wù)調(diào)度平臺(tái)通信，所述任務(wù)執(zhí)行器設(shè)置于云服務(wù)器和/或邊緣設(shè)備中，所述方法包括：

發(fā)送心跳注冊(cè)請(qǐng)求至所述任務(wù)調(diào)度平臺(tái)；所述心跳注冊(cè)請(qǐng)求包括所述任務(wù)執(zhí)行器的狀態(tài)信息；

按照固定間隔時(shí)間段向所述任務(wù)調(diào)度平臺(tái)發(fā)送任務(wù)獲取請(qǐng)求；

在接收到所述任務(wù)調(diào)度平臺(tái)返回的任務(wù)后，執(zhí)行所述任務(wù)。

7.一種任務(wù)調(diào)度平臺(tái)，其特征在于，所述任務(wù)調(diào)度平臺(tái)與任務(wù)執(zhí)行器通信，所述任務(wù)執(zhí)行器設(shè)置于云服務(wù)器和/或邊緣設(shè)備中，所述任務(wù)調(diào)度平臺(tái)包括：

心跳管理模塊，被配置成接收所述任務(wù)執(zhí)行器發(fā)送的心跳注冊(cè)請(qǐng)求；所述心跳注冊(cè)請(qǐng)求包括所述任務(wù)執(zhí)行器的狀態(tài)信息；

信箱生成模塊，被配置成響應(yīng)于接收到所述心跳注冊(cè)請(qǐng)求并生成所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)信箱；

任務(wù)派發(fā)模塊，被配置成根據(jù)所述任務(wù)執(zhí)行器的狀態(tài)信息將任務(wù)池中的任務(wù)派發(fā)至所述任務(wù)執(zhí)行器對(duì)應(yīng)的任務(wù)信箱。

8.一種任務(wù)執(zhí)行器，其特征在于，所述任務(wù)執(zhí)行器與任務(wù)調(diào)度平臺(tái)通信，所述任務(wù)執(zhí)行器設(shè)置于云服務(wù)器和/或邊緣設(shè)備中，所述任務(wù)執(zhí)行器被配置成：

發(fā)送心跳注冊(cè)請(qǐng)求至所述任務(wù)調(diào)度平臺(tái)；所述心跳注冊(cè)請(qǐng)求包括所述任務(wù)執(zhí)行器的狀態(tài)信息；

按照固定間隔時(shí)間段向所述任務(wù)調(diào)度平臺(tái)發(fā)送任務(wù)獲取請(qǐng)求；

在接收到所述任務(wù)調(diào)度平臺(tái)返回的任務(wù)后，執(zhí)行所述任務(wù)。

9.一種任務(wù)處理系統(tǒng)，其特征在于，包括：

根據(jù)權(quán)利要求7所述的任務(wù)調(diào)度平臺(tái)；

根據(jù)權(quán)利要求8所述的任務(wù)執(zhí)行器。

10.根據(jù)權(quán)利要求9所述的任務(wù)處理系統(tǒng)，其特征在于，所述任務(wù)調(diào)度平臺(tái)包括任務(wù)獲取接口，所述任務(wù)調(diào)度平臺(tái)通過(guò)所述任務(wù)獲取接口與每一任務(wù)執(zhí)行器、每一任務(wù)信箱進(jìn)行連接；

所述任務(wù)調(diào)度平臺(tái)通過(guò)所述任務(wù)獲取接口將每一任務(wù)信箱中的任務(wù)發(fā)送至對(duì)應(yīng)的任務(wù)執(zhí)行器；

所述任務(wù)執(zhí)行器通過(guò)所述任務(wù)獲取接口向所述任務(wù)信箱發(fā)送任務(wù)獲取請(qǐng)求，以使所述任務(wù)調(diào)度平臺(tái)根據(jù)所述任務(wù)獲取請(qǐng)求向?qū)?yīng)的任務(wù)執(zhí)行器派發(fā)任務(wù)。