[發明專利]批處理任務執行方法、系統以及機房部署系統

在審

• 申請號: 202010568593.7
• 申請日: 2020-06-19
• 公開（公告）號: CN111666144A
• 公開（公告）日: 2020-09-15
• 發明（設計）人: 劉娟;李軍剛;王志鋒;方錫銳;詹武州;喬雅正
• 申請（專利權）人: 中信銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京市蘭臺律師事務所 11354
• 代理人: 張峰

1.一種批處理任務執行方法，其特征在于，所述方法包括：

獲取多個批處理任務；

按照預設規則將多個所述批處理任務編排為多個批次，并確定各批次批處理任務的執行順序；其中，每個批次可以包括至少一個批處理任務，且每個批次的批處理任務具有相同或相近的任務屬性；

按照所述各批次批處理任務的執行順序，依次執行所述各批次批處理任務。

2.根據權利要求1所述的方法，其特征在于，所述按照預設規則將多個所述批處理任務編排為多個批次，并確定各批次批處理任務的執行順序，包括：

根據各所述批處理任務所屬的業務維度或數據流維度，將多個所述批處理任務編排為多個批次；

按照預設的優先級規則，分別確定各批次批處理任務的優先級；

根據所述各批次批處理任務的優先級，確定所述各批次批處理任務的執行順序。

3.根據權利要求2所述的方法，其特征在于，所述根據所述各批次批處理任務的優先級，確定所述各批次批處理任務的執行順序之前，所述方法還包括：

計算獲取各批次批處理任務的資源消耗量；

所述根據所述各批次批處理任務的優先級，確定所述各批次批處理任務的執行順序，包括：

根據所述各批次批處理任務的優先級、以及資源消耗量，確定所述各批次批處理任務的執行順序。

4.根據權利要求1-3任一項所述的方法，其特征在于，所述按照所述各批次批處理任務的執行順序，依次執行所述各批次批處理任務之前，所述方法還包括：

通過離線同步的方式將賬戶系統和授權系統的數據同步至分布式集群；

所述按照所述各批次批處理任務的執行順序，依次執行所述各批次批處理任務，包括：

按照所述各批次批處理任務的執行順序，基于所述分布式集群中所述賬戶系統和所述授權系統的數據，依次執行所述各批次批處理任務。

5.根據權利要求1-3任一項所述的方法，其特征在于，所述獲取多個批處理任務之前，所述方法還包括：

輪詢批處理啟動條件；

所述獲取多個批處理任務，包括：

獲取滿足批處理啟動條件的多個批處理任務。

6.一種批處理任務執行系統，其特征在于，所述系統包括：

批處理任務獲取模塊，用于獲取多個批處理任務；

批處理任務編排模塊，用于按照預設規則將多個所述批處理任務編排為多個批次，并確定各批次批處理任務的執行順序；其中，每個批次可以包括至少一個批處理任務，且每個批次的批處理任務具有相同或相近的任務屬性；

執行模塊，用于按照所述各批次批處理任務的執行順序，依次執行所述各批次批處理任務。

7.根據權利要求6所述的系統，其特征在于，所述批處理任務編排模塊，包括：

編排子模塊，用于根據各所述批處理任務所屬的業務維度或數據流維度，將多個所述批處理任務編排為多個批次；

優先級確定子模塊，用于按照預設的優先級規則，分別確定各批次批處理任務的優先級；

執行順序確定子模塊，用于根據所述各批次批處理任務的優先級，確定所述各批次批處理任務的執行順序。

8.根據權利要求7所述的系統，其特征在于，所述批處理任務編排模塊，還包括：

資源消耗量計算子模塊，用于在所述執行順序確定子模塊根據所述各批次批處理任務的優先級，確定所述各批次批處理任務的執行順序之前，計算獲取各批次批處理任務的資源消耗量；

所述執行順序確定子模塊，具體用于根據所述各批次批處理任務的優先級、以及資源消耗量，確定所述各批次批處理任務的執行順序。