[發明專利]基于批次調度中心的計劃任務執行方法以及系統

有效

• 申請號: 202010359516.0
• 申請日: 2020-04-30
• 公開（公告）號: CN111522630B
• 公開（公告）日: 2021-04-06
• 發明（設計）人: 羅孟波;翁國海
• 申請（專利權）人: 北京江融信科技有限公司
• 主分類號: G06F9/455
• 分類號: G06F9/455;G06F9/48
• 代理公司: 北京天盾知識產權代理有限公司 11421
• 代理人: 張彩珍

1.一種基于批次調度中心的計劃任務執行方法，其特征在于，包括：

步驟S1：分析各批次任務之間的關系，將各批次任務依序連接，生成一沿固定方向的任務執行流程圖，其中每個任務節點關聯配置一個批次執行任務，并向用戶展示所述任務執行流程圖；

步驟S2：根據任務執行流程圖的各個節點順序依次執行完成任務執行流程圖的全部任務；

其中，在任務執行過程中，在所述任務執行流程圖中以不同色彩實時標識各個批次任務的執行狀態，并允許用戶對各個批次任務進行操作以監控任務執行進程；以及

每個批次任務對應至少一個任務分區，每個任務分區通過調用DFS應用服務拉起一個相應的pod容器，各個pod容器的參數由批次調度中心統一配置以使得各個pod容器具有各自獨立的資源空間；

其中，當某個任務節點所關聯的任務開始執行時，該任務節點所指向的所有下一級任務節點同時針對所有任務分區拉起相關的pod容器以進行預加載，啟動相應的pod應用但并不執行相關任務，只有當監聽到該pod應用為可執行狀態時才開始執行相關任務，當某個任務節點正在運行中，此任務節點的后續任務會優先拉起容器pod并啟動批次應用程序，并且監聽pod對應的分區執行狀態，當監聽的狀態一旦為可運行時，立馬執行此應用的業務程序，而中間的拉起容器pod和啟動應用程序的過程都在前任務運行時就已經完成；

所述DFS應用服務集成于批次調度中心，批次調度中心在執行任務時，通過集成在批次調度中心的DFS應用服務拉起執行批次任務進程，批次調度中心執行任務時，會通過集成在批次調度中心的DFS應用代碼拉起執行批次任務進程，不需要在通過再次請求中間服務器DFS去拉起批次任務進程。

2.如權利要求1所述的計劃任務執行方法，其特征在于，所述用戶對各個批次任務進行操作以監控任務執行進程包括以下操作中的一個或多個：查看執行記錄、暫停執行、取消暫停、異常重跑。

3.如權利要求1所述的計劃任務執行方法，其特征在于，所述步驟S2中包括：

步驟S21：啟動執行計劃；

步驟S22：以開始節點找到其指向的所有任務節點并依次執行各個任務節點關聯的任務；

步驟S23：當一個任務節點關聯的任務執行成功后，找到該任務節點指向的所有下一級任務節點并依次執行下一級任務節點所關聯的任務；

步驟S24：以此類推，直到整個任務執行流程圖中的所有任務全部執行成功。

4.一種基于批次調度中心的計劃任務執行系統，其特征在于，包括：

繪圖單元，分析各批次任務之間的關系，將各批次任務依序連接，生成一沿固定方向的任務執行流程圖，其中每個任務節點關聯配置一個批次執行任務，并向用戶展示所述任務執行流程圖；

批次調度中心，根據任務執行流程圖的各個節點順序依次執行完成任務執行流程圖的全部任務；

其中，在任務執行過程中，在所述任務執行流程圖中以不同色彩實時標識各個批次任務的執行狀態，并允許用戶對各個批次任務進行操作以監控任務執行進程；以及

每個批次任務對應至少一個任務分區，每個任務分區通過調用DFS應用服務拉起一個相應的pod容器，各個pod容器的參數由批次調度中心統一配置以使得各個pod容器具有各自獨立的資源空間；

其中，當某個任務節點所關聯的任務開始執行時，該任務節點所指向的所有下一級任務節點同時針對所有任務分區拉起相關的pod容器以進行預加載，啟動相應的pod應用但并不執行相關任務，只有當監聽到該pod應用為可執行狀態時才開始執行相關任務，當某個任務節點正在運行中，此任務節點的后續任務會優先拉起容器pod并啟動批次應用程序，并且監聽pod對應的分區執行狀態，當監聽的狀態一旦為可運行時，立馬執行此應用的業務程序，而中間的拉起容器pod和啟動應用程序的過程都在前任務運行時就已經完成；

所述DFS應用服務集成于批次調度中心，批次調度中心在執行任務時，通過集成在批次調度中心的DFS應用服務拉起執行批次任務進程，批次調度中心執行任務時，會通過集成在批次調度中心的DFS應用代碼拉起執行批次任務進程，不需要在通過再次請求中間服務器DFS去拉起批次任務進程。