[發明專利]分布式任務調度的方法、任務調度平臺及任務執行器

在審

• 申請號: 202011623937.6
• 申請日: 2020-12-31
• 公開（公告）號: CN112685184A
• 公開（公告）日: 2021-04-20
• 發明（設計）人: 吳曉富
• 申請（專利權）人: 廣州極飛科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京潤平知識產權代理有限公司 11283
• 代理人: 陳瀟瀟

本發明實施例公開了一種分布式任務調度的方法、任務調度平臺及任務執行器。任務調度平臺與任務執行器通信，任務執行器設置于云服務器和/或邊緣設備中，該方法包括：接收任務執行器發送的心跳注冊請求，心跳注冊請求包括任務執行器的狀態信息；響應于接收到心跳注冊請求，生成任務執行器對應的任務信箱；根據任務執行器的狀態信息將任務池中的任務派發至任務執行器對應的任務信箱。這樣，任務執行器能夠同時工作于服務器和邊緣設備，且一臺機器能夠部署多個任務執行器，能夠有效提高分布式任務調度的計算資源利用率。

技術領域

本發明涉及計算機技術領域，具體地涉及一種分布式任務調度的方法、任務調度平臺及任務執行器。

背景技術

現有的分布式任務調度系統幾乎都是針對云服務器架構體系來設計，調度中心和任務執行器都需要固定的互聯網協議(Internet Protocol，IP)地址，兩者需要進行雙向通訊，大致過程為：任務執行器向調度中心注冊，調度中心主動發送任務給任務執行器，任務執行器執行完后回復執行結果給調度中心。基于雙向通信架構的調度中心和任務執行器都需要預先設定機器的IP地址，調度中心根據任務執行器的IP地址，識別任務執行器并直接發送任務給執行器。對于邊緣設備來說，幾乎都是動態IP分配，因此，無法接入現有的任務調度體系中，無法有效利用數量龐大的計算資源。基于機器級別的任務執行器識別，限制了一臺機器只能部署一個任務執行器，往往云服務器的性能較好，能夠同時運行多個任務執行器。因此，傳統的分布式調度系統在一定程度上會造成資源的浪費。

發明內容

本發明實施例的目的是提供一種分布式任務調度的方法、任務調度平臺及任務執行器。用以解決傳統的分布式調度系統在一定程度上會造成資源浪費的問題。

為了實現上述目的，本發明第一方面提供一種分布式任務調度的方法，應用于任務調度平臺，任務調度平臺與任務執行器通信，任務執行器設置于云服務器和/或邊緣設備中，該方法包括：

接收任務執行器發送的心跳注冊請求，心跳注冊請求包括任務執行器的狀態信息；

響應于接收到心跳注冊請求，生成任務執行器對應的任務信箱；

根據任務執行器的狀態信息將任務池中的任務派發至任務執行器對應的任務信箱。

在本發明的實施例中，任務執行器的狀態信息包括以下至少一項：

任務執行器的通用唯一識別碼、任務執行器的節點狀態；

根據任務執行器的狀態信息將任務池中的任務派發至任務執行器對應的任務信箱，包括：

獲取任務池中的每一任務對應的通用唯一識別碼，以確定每一任務對應的任務執行器；

根據通用唯一識別碼確定每一任務對應任務信箱，并將每一任務派發至對應的任務信箱。

在本發明的實施例中，該方法還包括：

獲取任務執行器固定間隔時間段發送的任務獲取請求；

根據任務獲取請求從對應的任務信箱取出一個任務信息返回任務執行器。

在本發明的實施例中，任務獲取請求中包括對應的任務執行器的唯一識別碼；

根據任務獲取請求從對應的任務信箱取出一個任務返回任務執行器，包括：

根據任務獲取請求中的唯一識別碼確定任務獲取請求對應的目標任務執行器和目標任務信箱；

從目標任務信箱中獲取對應的任務信息，并將任務信息發送至目標任務執行器。

在本發明的實施例中，該方法還包括：

獲取任務執行器發送的任務處理信息，任務處理信息包括任務執行器對應的任務處理進度信息；

將任務處理信息存儲于數據庫。