[發明專利]失敗任務的補償管理方法、裝置、計算機設備及存儲介質

在審

• 申請號: 202010147107.4
• 申請日: 2020-03-05
• 公開（公告）號: CN111475515A
• 公開（公告）日: 2020-07-31
• 發明（設計）人: 劉芳;李琳
• 申請（專利權）人: 深圳壹賬通智能科技有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/2458;G06F16/27
• 代理公司: 深圳市世聯合知識產權代理有限公司 44385
• 代理人: 汪琳琳

1.一種失敗任務的補償管理方法，其特征在于，包括：

在數據庫中對數據更新任務的同步結果進行記錄；

實時檢測數據庫中的新增記錄，以獲取所述新增記錄中對同步結果記錄為失敗的數據更新任務；

激活預設的執行時間間隔為t的定時補償任務，所述定時補償任務用于依次對同步結果記錄為失敗的所述數據更新任務重新推送進行再次同步；

基于所述定時補償任務的補償執行結果更新所述數據庫中對所述數據更新任務的同步結果的記錄。

2.根據權利要求1所述的失敗任務的補償管理方法，其特征在于，所述在數據庫中對數據更新任務的同步結果進行記錄的步驟包括：

若數據更新任務的同步結果為失敗，且所述數據更新任務屬于新增和修改操作，則在數據庫的表單中設置用于表示所述同步結果為失敗的標識符；

若數據更新任務的同步結果為失敗，且所述數據更新任務屬于刪除操作，則在redis中生成日志以記錄所述刪除操作的對象和同步結果。

3.根據權利要求2所述的失敗任務的補償管理方法，其特征在于，所述方法還包括：

通過所述定時補償任務依次對操作內容為新增、修改和刪除的數據更新任務執行重新推送進行再次同步；

若再次同步時同步成功，則將對應在表單中設置的所述標識符進行更新以表示所述同步結果為成功，或在redis中將對應記錄的所述日志刪除。

4.根據權利要求1所述的失敗任務的補償管理方法，其特征在于，在所述激活預設的執行時間間隔為t的定時補償任務的步驟之前，所述方法還包括：

獲取待激活的定時補償任務對應的redis鎖狀態，以判斷所述定時補償任務對應的操作是否已上鎖；

若已上鎖，則停止所述定時補償任務；若未上鎖，則為所述定時補償任務的操作上鎖后執行所述定時補償任務，并在所述定時補償任務執行完成后對其redis鎖進行解鎖。

5.根據權利要求4所述的失敗任務的補償管理方法，其特征在于，所述停止所述定時補償任務的步驟之后，所述方法還包括：

輪詢所述定時補償任務的redis鎖狀態；

當檢測到所述redis鎖已解鎖后，獲取所述定時補償任務對應操作的當前同步結果；

若所述當前同步結果仍記錄為失敗，則重新激活所述定時補償任務。

6.根據權利要求4所述的失敗任務的補償管理方法，其特征在于，在所述激活預設的執行時間間隔為t的定時補償任務的步驟之后，所述方法還包括：

實時監控所述定時補償任務的執行時間；

當所述執行時間超過預設的過期時間時，對所述定時補償任務的redis鎖進行強制釋放。

7.根據權利要求1所述的失敗任務的補償管理方法，其特征在于，在所述激活預設的執行時間間隔為t的定時補償任務的步驟之后，所述方法還包括：

記錄每個數據更新任務對應的定時補償任務的執行次數；

當一個數據更新任務對應的定時補償任務的執行次數達到預設的執行閾值時，停止對該數據更新任務的定時補償任務。

8.一種失敗任務的補償管理裝置，其特征在于，包括：

數據記錄模塊，用于在數據庫中對數據更新任務的同步結果進行記錄；

記錄查詢模塊，用于實時檢測數據庫中的新增記錄，以獲取所述新增記錄中對同步結果記錄為失敗的數據更新任務；

任務激活模塊，用于激活執行的時間間隔為t的定時補償任務，所述定時補償任務用于依次對同步結果記錄為失敗的所述數據更新任務重新推送進行再次同步；

數據更新模塊，用于基于所述定時補償任務的補償執行結果更新所述數據庫中對所述數據更新任務的同步結果的記錄。

9.一種計算機設備，包括存儲器和處理器，其特征在于，所述存儲器中存儲有計算機程序，所述處理器執行所述計算機程序時實現如權利要求1-7中任意一項所述的失敗任務的補償管理方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現如權利要求1-7中任意一項所述的失敗任務的補償管理方法的步驟。