[發明專利]一種數據處理方法及裝置

在審

• 申請號: 202011049660.0
• 申請日: 2020-09-29
• 公開（公告）號: CN112114973A
• 公開（公告）日: 2020-12-22
• 發明（設計）人: 陳驁
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54;G06Q40/02
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 柳虹

1.一種數據處理方法，其特征在于，包括：

利用任務拆分規則對待處理任務進行拆分，得到多個子任務；所述多個子任務具有任務緊急指數；

根據所述多個子任務的任務緊急指數，將所述多個子任務分配至RabbitMQ中的多個任務隊列中的至少一個；所述多個任務隊列具有不同的優先級；所述優先級根據所述任務隊列的隊列緊急指數和時間權重確定，所述隊列緊急指數表征所述任務隊列的緊急程度，所述時間權重根據所述任務隊列中子任務的未被執行時長確定；所述任務隊列的隊列緊急指數與所述任務隊列中的子任務的任務緊急指數匹配；

通過分布式節點訂閱到RabbitMQ，根據所述多個任務隊列的優先級，獲取并執行所述多個子任務。

2.根據權利要求1所述的方法，其特征在于，所述多個子任務的任務信息以及任務狀態存儲在redis任務池中，所述任務狀態包括未執行、正在執行、完成執行、執行錯誤中的一種。

3.根據權利要求2所述的方法，其特征在于，所述方法還包括：

在所述子任務的任務狀態為執行錯誤時，將所述子任務重新分配至任務隊列中進行執行。

4.根據權利要求1-3任意一項所述的方法，其特征在于，所述方法還包括：

在所述待處理任務的多個子任務均完成執行后，對所述多個子任務的執行結果進行歸并，得到所述待處理任務的執行結果。

5.根據權利要求1-3任意一項所述的方法，其特征在于，所述方法還包括：

在所述待處理任務的多個子任務均完成執行后，根據所述多個子任務的執行時長以及耗費資源數，更新所述任務拆分規則。

6.一種數據處理裝置，其特征在于，包括：

任務拆分單元，用于利用任務拆分規則對待處理任務進行拆分，得到多個子任務；所述多個子任務具有任務緊急指數；

任務分配單元，用于根據所述多個子任務的任務緊急指數，將所述多個子任務分配至RabbitMQ中的多個任務隊列中的至少一個；所述多個任務隊列具有不同的優先級；所述優先級根據所述任務隊列的隊列緊急指數和時間權重確定，所述隊列緊急指數表征所述任務隊列的緊急程度，所述時間權重根據所述任務隊列中子任務的未被執行時長確定；所述任務隊列的隊列緊急指數與所述任務隊列中的子任務的任務緊急指數匹配；

任務執行單元，用于通過分布式節點訂閱到RabbitMQ，根據所述多個任務隊列的優先級，獲取并執行所述多個子任務。

7.根據權利要求6所述的裝置，其特征在于，所述多個子任務的任務信息以及任務狀態存儲在redis任務池中，所述任務狀態包括未執行、正在執行、完成執行、執行錯誤中的一種。

8.根據權利要求7所述的裝置，其特征在于，所述裝置還包括：

任務再執行單元，用于在所述子任務的任務狀態為執行錯誤時，將所述子任務重新分配至任務隊列中進行執行。

9.根據權利要求6-8任意一項所述的裝置，其特征在于，所述裝置還包括：

任務歸并單元，用于在所述待處理任務的多個子任務均完成執行后，對所述多個子任務的執行結果進行歸并，得到所述待處理任務的執行結果。

10.根據權利要求6-8任意一項所述的方法，其特征在于，所述裝置還包括：

規則更新單元，用于在所述待處理任務的多個子任務均完成執行后，根據所述多個子任務的執行時長以及耗費資源數，更新所述任務拆分規則。