[發明專利]數據遷移方法、裝置、計算機設備及存儲介質

在審

• 申請號: 202210037709.3
• 申請日: 2022-01-13
• 公開（公告）號: CN114385595A
• 公開（公告）日: 2022-04-22
• 發明（設計）人: 姜雷
• 申請（專利權）人: 平安付科技服務有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/27
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 武志峰

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

在源端數據庫中，基于賬戶信息，生成分庫值標記，并根據所述分庫值標記，將所述賬戶信息對應的數據進行打標分庫，得到初始分庫值，以及將所述分庫值標記對應的初始分庫值作為臨時分庫值，將除所述臨時分庫值以外的分庫值對應的初始分庫值作為目標分庫值；

構建所述目標分庫值對應的目標分庫，以及構建所述臨時分庫值對應的臨時分庫，并構建所述源端數據庫與所述目標分庫之間數據鏈路，得到目標數據鏈路；

根據數據同步命令，獲取所述目標分庫值對應的數據，并基于所述目標數據鏈路，將所述目標分庫值對應的數據從所述源端數據庫同步到所述目標分庫中；

當檢測到所述賬戶號發生變更信息時，獲取所述賬戶號發生變更信息對應的初始分庫值，作為變更分庫值，并將所述變更分庫值轉換成所述臨時分庫值；

當所述目標分庫值對應的數據同步完成時，基于所述臨時分庫值，構建所述源端數據庫與所述臨時分庫之間數據鏈路，得到臨時數據鏈路；

基于所述臨時數據鏈路，將所述臨時分庫值對應的數據，從所述源端數據庫同步到所述臨時分庫中。

2.根據權利要求1所述的數據遷移方法，其特征在于，所述在源端數據庫中，基于賬戶信息，生成分庫值標記，并根據所述分庫值標記，將所述賬戶信息對應的數據進行打標分庫，得到初始分庫值，以及將所述分庫值標記對應的初始分庫值作為臨時分庫值，將除所述臨時分庫值以外的分庫值對應的初始分庫值作為目標分庫值，包括：

獲取所述源端數據庫中的所述賬戶信息，其中，所述賬戶信息包括所述賬戶號；

獲取所述賬戶信息對應的數據，作為待打標數據；

基于所述賬戶號，生成所述分庫值標記，并基于所述分庫值標記，將所述賬戶號對應的所述待打標數據進行打標分庫，得到所述初始分庫值；

將所述分庫值標記對應的初始分庫值作為臨時分庫值，將除所述臨時分庫值以外的分庫值對應的初始分庫值作為目標分庫值。

3.根據權利要求1所述的數據遷移方法，其特征在于，所述構建所述目標分庫值對應的目標分庫，以及構建所述臨時分庫值對應的臨時分庫，并構建所述源端數據庫與所述目標分庫之間數據鏈路，得到目標數據鏈路，包括：

基于所述目標分庫值的分庫值標記，構建所述目標分庫，所述目標分庫包括所述目標分庫值的分庫值標記；

基于所述臨時分庫值的分庫值標記，構建所述臨時分庫，所述臨時分庫包括所述臨時分庫值的分庫值標記；

構建所述源端數據庫與所述目標分庫之間數據鏈路，得到目標數據鏈路，并基于所述數據鏈路，生成所述源端數據庫與所述目標分庫之間的數據傳輸通道。

4.根據權利要求3所述的數據遷移方法，其特征在于，所述構建所述源端數據庫與所述目標分庫之間數據鏈路，得到目標數據鏈路，并基于所述數據鏈路，生成所述源端數據庫與所述目標分庫之間的數據傳輸通道，包括：

構建所述源端數據庫與所述目標分庫之間數據鏈路，得到所述目標數據鏈路；

采用預置的Docker組件和Kubernetes組件，分別在所述源端數據庫和所述目標分庫建立多個應用容器；

基于預置的Zookeeper組件，分別在各個所述應用容器中創建配置文件，生成Zookeeper實例；

通過將各個所述應用容器中配置文件的參數設置為相同，建立各個所述應用容器中的Zookeeper實例之間的通信連接，以構建出Zookeeper消息集群；

將預置的Kafka組件注冊至所述Zookeeper消息集群中，獲得所述源端數據庫與所述目標分庫之間的所述數據傳輸通道。