[發明專利]一種中斷任務恢復方法及裝置

在審

• 申請號: 201910888051.5
• 申請日: 2019-09-19
• 公開（公告）號: CN110618864A
• 公開（公告）日: 2019-12-27
• 發明（設計）人: 堵新政;張毅然
• 申請（專利權）人: 北京明略軟件系統有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 11240 北京康信知識產權代理有限責任公司
• 代理人: 張秀英

本發明提供了一種中斷任務恢復方法及裝置，其中，該方法包括：以第一預定時間周期監控目標任務的進程和狀態；根據所述目標任務的進程和狀態確定目標任務是否發生異常中斷；在所述目標任務發生異常中斷的情況下，以第二預定時間周期重新啟動所述目標任務；在所述目標任務在預定重啟次數之內重啟成功的情況下，創建與所述目標任務對應的第二目標進程，并維護所述目標任務與所述第二目標進程的映射關系，因此，可以解決相關技術中任務異常中斷不能及時恢復，造成計算資源閑置、業務數據處理流程無法進行的問題，實現了及時恢復中斷的任務，避免計算資源閑置，使得業務數據處理流程可以正常進行。

技術領域

本發明涉及計算機領域，具體而言，涉及一種中斷任務恢復方法及裝置。

背景技術

隨著計算機網絡技術的發展，以及數據處理量的增長，分布式數據處理系統得到廣泛應用。

分布式數據處理系統包括多個任務節點，多個任務節點可以同時進行數據處理，大幅度提高了系統的數據處理效率。

在大數據治理過程中，每個階段都會產生不同量級的計算任務，如采集任務、轉換任務、清洗任務、融合任務等。這些任務使用集群機器的計算資源(CPU、內存等)，分工協作，完成整個業務數據的處理。這些任務有獨立任務，也有依賴任務，無論哪一種任務，如果由于異常原因導致任務中斷，這時如果不能及時恢復就會造成資源的閑置和浪費，甚至影響業務流程的正常進行。尤其對于依賴任務，當前置任務中斷后，其所有的后置任務都無法進行。而依靠人工恢復，不僅耗時耗力，很難保障任務恢復的及時。

針對相關技術中任務異常中斷不能及時恢復，造成計算資源閑置、業務數據處理流程無法進行的問題，尚未提出解決方案。

發明內容

本發明實施例提供了一種中斷任務恢復方法及裝置，以至少解決相關技術中任務異常中斷不能及時恢復，造成計算資源閑置、業務數據處理流程無法進行的問題。

根據本發明的一個實施例，提供了一種中斷任務恢復方法，包括：

以第一預定時間周期監控目標任務的進程和狀態；

根據所述目標任務的進程和狀態確定目標任務是否發生異常中斷；

在所述目標任務發生異常中斷的情況下，以第二預定時間周期重新啟動所述目標任務；

在所述目標任務在預定重啟次數之內重啟成功的情況下，創建與所述目標任務對應的第二目標進程，并維護所述目標任務與所述第二目標進程的映射關系。

可選地，根據所述目標任務的進程和狀態信息確定目標任務是否發生異常中斷包括：

檢測是否存在與所述目標任務對應的第一目標進程；

在檢測結果為存在所述目標任務對應的所述第一目標進程的情況下，確定所述目標任務發生異常中斷；

在檢測結果為存在所述目標任務對應的所述第一目標進程且所述目標任務的狀態為失敗狀態的情況下，確定所述目標任務發生異常中斷；

在所述目標任務對應的所述第一目標進程存在且所述目標任務的狀態為運行狀態的情況下，確定所述目標任務未發生異常中斷。

可選地，在以第二預定時間周期重新啟動所述目標任務之前，所述方法還包括：

在存在所述目標任務對應的所述第一目標進程的情況下，將所述第一目標進程殺死。

可選地，在以第二預定時間周期重新啟動所述目標任務之后，所述方法還包括：

若所述目標任務的狀態為失敗狀態，將所述目標任務的狀態由所述失敗狀態轉換為所述運行狀態。

可選地，在以第一預定時間周期監控目標任務的進程和狀態之前，所述方法還包括：