[發明專利]數據遷移方法、裝置、設備、分布式系統及存儲介質

有效

• 申請號: 202010923655.1
• 申請日: 2020-09-04
• 公開（公告）號: CN111797172B
• 公開（公告）日: 2021-03-23
• 發明（設計）人: 羅燕新;李飛飛;曹偉
• 申請（專利權）人: 阿里云計算有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F3/06
• 代理公司: 北京博思佳知識產權代理有限公司 11415
• 代理人: 周嗣勇

1.一種數據遷移方法，應用于包括多個數據節點的分布式系統中的每個數據節點上，所述方法包括：

確定本次數據遷移任務中本節點的待遷移表以及目標數據節點；

將所述待遷移表的遷移狀態確定為第一狀態；其中，所述第一狀態指示能夠對增量數據采用雙寫的操作方式；

將指示所述第一狀態的狀態信息同步給所述目標數據節點，以使所述目標數據節點將所述目標數據節點的目標數據表的遷移狀態確定為所述第一狀態；

在所述待遷移表和所述目標數據表的遷移狀態均為第一狀態的情況下，將所述待遷移表中的增量數據寫入所述待遷移表以及所述目標數據節點的目標數據表中；所述增量數據為在確定所述待遷移表和所述目標數據表的遷移狀態均為所述第一狀態之后，對所述待遷移表中的數據進行更改操作得到的數據。

2.根據權利要求1所述的方法，在所述確定本次數據遷移任務中本節點的待遷移表以及目標數據節點之后，還包括：

從本節點的數據庫中獲取所述待遷移表的元數據；

根據所述元數據在所述目標數據節點的數據庫中建立所述目標數據表。

3.根據權利要求1所述的方法，還包括：

將所述待遷移表中的存量數據寫入所述目標數據節點的目標數據表，所述存量數據為在確定所述待遷移表和所述目標數據表的遷移狀態均為所述第一狀態之前所述待遷移表中的數據。

4.根據權利要求3所述的方法，在將所述待遷移表中的增量數據寫入所述待遷移表以及所述目標數據節點的目標數據表中之前，還包括：

記錄位點信息，所述位點信息指示在將增量數據寫入所述待遷移表以及所述目標數據表之前，所述待遷移表中的主鍵的取值范圍；

所述將所述待遷移表中的存量數據寫入所述目標數據節點的目標數據表，包括：

獲取所述待遷移表的所述位點信息；

根據所述位點信息指示的所述待遷移表中的主鍵的取值范圍，確定所述待遷移表中的存量數據；

讀取所述待遷移表中的存量數據并寫入所述目標數據表。

5.根據權利要求3所述的方法，在所述待遷移表和所述目標數據表的遷移狀態均為第二狀態的情況下，執行將所述存量數據寫入所述目標數據表的操作；

則在所述將所述待遷移表中的存量數據寫入所述目標數據節點的目標數據表之前，還包括：

將所述待遷移表的遷移狀態確定為第二狀態；所述第二狀態指示將所述待遷移表的存量數據寫入所述目標數據表中；

將指示所述第二狀態的狀態信息同步給所述目標數據節點，以使所述目標數據節點將所述目標數據表的遷移狀態確定為所述第二狀態；所述第一狀態和所述第二狀態共存。

6.根據權利要求1或5所述的方法，對所述遷移表中的數據進行的更改操作、以及確定所述待遷移表和所述目標數據表的遷移狀態的操作為互斥操作。

7.根據權利要求6所述的方法，所述對所述待遷移表中的數據進行的更改操作是在獲取針對于所述待遷移表的讀鎖之后進行的；

所述確定所述待遷移表和所述目標數據表的遷移狀態的操作是在獲取針對于所述待遷移表的寫鎖之后進行的；所述讀鎖和所述寫鎖為互斥鎖。

8.根據權利要求3所述的方法，在將所述待遷移表中的增量數據寫入所述待遷移表以及所述目標數據節點的目標數據表中之前，還包括：

記錄位點信息，所述位點信息指示在確定所述待遷移表和所述目標數據表的遷移狀態均為所述第一狀態之前所述待遷移表中的主鍵的取值范圍；所述位點信息用于確定所述待遷移表的存量數據。

9.根據權利要求3所述的方法，還包括：

在所述存量數據寫入完成之后，向所述目標數據節點發送切換請求，所述切換請求用于將對所述待遷移表的讀操作切換至所述目標數據表；以及，

在切換完成后停止對所述待遷移表的寫操作。

10.根據權利要求9所述的方法，對所述遷移表中的數據進行的更改操作和所述將對所述待遷移表的讀操作切換至所述目標數據表的操作為互斥操作。