[發明專利]一種流水文件裝載方法、裝置、服務器和存儲介質

在審

• 申請號: 202011025765.2
• 申請日: 2020-09-25
• 公開（公告）號: CN112181917A
• 公開（公告）日: 2021-01-05
• 發明（設計）人: 賴韜;郭敏鴻;蔡躍進;侯戩;羅旋;李運璇
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F16/172
• 分類號: G06F16/172;G06F9/50;G06F11/20
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種流水文件裝載方法，其特征在于，所述方法包括：

確定執行流水文件裝載任務的目標服務器分組；其中，目標服務器分組中包括服務器集群中的至少兩個服務器節點；

將所述流水文件裝載任務下發到目標服務器分組，以使得目標服務器分組中的各服務器節點并行執行所述流水文件裝載任務；

每間隔預設時間，執行分組輪換操作，以將所述流水文件裝載任務切換到下一個服務器分組，使得下一個服務器分組中的各服務器節點繼續并行執行所述流水文件裝載任務。

2.根據權利要求1所述的方法，其特征在于，確定執行流水文件裝載任務的目標服務器分組之前，還包括：

基于預設分組規則，對所述服務器集群進行分組，得到至少兩個服務器分組。

3.根據權利要求2所述的方法，其特征在于，所述預設分組規則為平均分組規則或負荷分組規則。

4.根據權利要求1所述的方法，其特征在于，各服務器節點并行執行所述流水文件裝載任務的過程，包括：

各服務器節點分別訪問共享緩存裝置，并讀取各自對應的流水文件；其中，所述共享緩存裝置用于緩存實時產生的流水文件；

各服務器節點將各自讀取到的流水文件裝載到目標數據庫。

5.根據權利要求4所述的方法，其特征在于，所述共享緩存裝置預先掛載到服務器集群的各個節點服務器上。

6.根據權利要求4所述的方法，其特征在于，各服務器節點讀取各自對應的流水文件的過程，包括：

針對任一服務器節點，該服務器節點依次遍歷共享緩存裝置中的各個流水文件，每遍歷到一個流水文件，則根據該流水文件的文件名，確定是否讀取該流水文件。

7.根據權利要求6所述的方法，其特征在于，所述流水文件以時間戳作為文件名后綴；

相應的，根據該流水文件的文件名，確定是否讀取該流水文件，包括：

將該流水文件的文件名后綴的最后一位數字與服務器分組內的服務器節點的數量進行求模運算；

根據求模運算結果，確定是否讀取該流水文件。

8.根據權利要求7所述的方法，其特征在于，根據求模運算結果，確定是否讀取該流水文件，包括：

獲取該服務器節點在服務器分組內的排序序號；

判斷所述求模運算結果與所述排序序號是否相同，若是，則確定讀取該流水文件。

9.根據權利要求4所述的方法，其特征在于，所述目標數據庫為關系數據庫。

10.根據權利要求1所述的方法，其特征在于，執行分組輪換操作的過程包括：

控制正在執行流水文件裝載任務的服務器節點停止執行裝載任務，并確定下一個繼續執行流水文件裝載任務的服務器分組。

11.根據權利要求4所述的方法，其特征在于，在將流水文件裝載到目標數據庫之后，所述方法還包括：

響應于用戶導出操作，將目標數據庫中的流水文件導出，以便根據導出的流水文件進行數據分析。

12.根據權利要求1-11任一項所述的方法，其特征在于，所述流水文件至少包括如下任意一項：POS繳費流水文件、存取款交易流水文件和轉賬流水文件。

13.一種流水文件裝載裝置，其特征在于，所述裝置包括：

確認模塊，用于確定執行流水文件裝載任務的目標服務器分組；其中，目標服務器分組中包括服務器集群中的至少兩個服務器節點；

裝載任務執行模塊，用于將所述流水文件裝載任務下發到目標服務器分組，以使得目標服務器分組中的各服務器節點并行執行所述流水文件裝載任務；

切換執行模塊，用于每間隔預設時間，執行分組輪換操作，以將所述流水文件裝載任務切換到下一個服務器分組，使得下一個服務器分組中的各服務器節點繼續并行執行所述流水文件裝載任務。