[發明專利]批量作業執行方法、裝置、設備、介質和產品

在審

• 申請號: 202111574616.6
• 申請日: 2021-12-21
• 公開（公告）號: CN114240632A
• 公開（公告）日: 2022-03-25
• 發明（設計）人: 黎錫軍;李丹;邱韜奮;徐策
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06Q40/02
• 分類號: G06Q40/02;G06Q10/06
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 駱文欣

1.一種批量作業執行方法，其特征在于，包括：

獲取當前批量作業節點中每個待處理作業的當前屬性信息；其中，每個批量作業節點中至少包括兩個待處理作業，并且，每個批量作業節點之間的依賴關系為上下層關系；每個批量作業節點之間的執行順序為串行執行，以及每個批量作業節點中每個待處理作業的執行順序為并行執行；

根據所述當前屬性信息中的業務數據量確定對應待處理作業的執行時間；

根據所述執行時間實時調整對應待處理作業在所述當前批量作業節點中的執行順序；

按照所述執行順序執行所述當前批量作業節點中的所有待處理作業。

2.根據權利要求1所述的方法，其特征在于，在所述獲取當前批量作業節點中每個待處理作業的當前屬性信息之前，包括：

根據批量待處理作業中每個待處理作業之間的作業依賴關系和時效性對所述批量待處理作業進行劃分，得到至少兩個批量作業節點。

3.根據權利要求1所述的方法，其特征在于，在所述按照所述執行順序執行所述當前批量作業節點中的所有待處理作業之后，還包括：

確定所述當前批量作業節點中所有待處理作業的執行結果；

在所述執行結果為已完成時，將下一個批量作業節點作為當前批量作業節點，并返回執行所述獲取當前批量作業節點中每個待處理作業的當前屬性信息的步驟，直至完成所有批量作業節點中所有待處理作業的執行。

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

將每個所述批量作業節點的當前屬性信息以鍵值對的形式存儲至預先創建的全局變量池中。

5.根據權利要求1-4任一所述的方法，其特征在于，每個所述待處理作業所對應業務數據量的確定方式，包括：

獲取每個所述待處理作業所關聯的數據表和數據文件；

根據所述數據表的業務數據量和所述數據文件的業務數據量確定對應所述待處理作業的業務數據量。

6.根據權利要求1-4任一所述的方法，其特征在于，所述根據所述當前屬性信息中的業務數據量確定對應待處理作業的執行時間，包括：

將所述當前屬性信息中的業務數據量輸入至預先創建的線性回歸模型；

通過所述線性回歸模型確定對應待處理作業的執行時間。

7.根據權利要求6所述的方法，其特征在于，所述線性回歸模型的創建方式，包括：

采用線性回歸算法，并以批量待處理作業中每個待處理作業所關聯數據表和數據文件所對應的業務數據量作為變量，對所述待處理作業的執行時間進行建模，得到對應的線性回歸模型。

8.根據權利要求1-4任一所述的方法，其特征在于，所述根據所述執行時間實時調整對應待處理作業在所述當前批量作業節點中的執行順序，包括：

根據所述執行時間確定對應待處理作業的目標執行編號；

按照所述目標執行編號實時調整所述待處理作業在所述當前批量作業節點中的執行順序。

9.根據權利要求8所述的方法，其特征在于，所述根據所述執行時間確定對應待處理作業的目標執行編號，包括：

按照所述執行時間對所述當前批量作業節點中的每個待處理作業進行降序排序，得到有序執行隊列；

按照所述有序執行隊列確定對應待處理作業的目標執行編號。

10.根據權利要求1-4任一所述的方法，其特征在于，在可執行線程數量為至少兩個的情況下，所述按照所述執行順序執行所述當前批量作業節點中的所有待處理作業，包括：

按照所述執行順序依次將所述當前批量作業節點中的所有待處理作業分配至對應的可執行線程上；

通過所述可執行線程并行執行所述當前批量作業節點中的所有待處理作業。