本文中含有需要您注意的重要提示信息,忽略該信息可能對您的業務造成影響,請務必仔細閱讀。
數據傳輸服務DTS(Data Transmission Service)支持MySQL數據庫間的雙向數據同步。本文以RDS MySQL實例間的雙向數據同步為例,為您介紹相關操作步驟。
前提條件
已創建源和目標RDS MySQL實例,創建方式,請參見創建RDS MySQL實例。
建議源和目標RDS MySQL實例的存儲空間保持一致。
注意事項
在庫表結構同步過程中,DTS會將源數據庫中的外鍵同步到目標數據庫。
在全量同步和增量同步過程中,DTS會以Session級別暫時禁用約束檢查以及外鍵級聯操作。若任務運行時源庫存在級聯更新、刪除操作,可能會導致數據不一致。
類型 | 說明 |
源和目標庫限制 |
|
其他限制 |
|
特殊情況 |
|
費用說明
同步類型 | 鏈路配置費用 |
庫表結構同步和全量數據同步 | 不收費。 |
增量數據同步 | 收費,詳情請參見計費概述。 |
支持的沖突檢測
為保障同步數據的一致性,您需要確保同一個主鍵、業務主鍵或唯一鍵的記錄只在雙向同步的一個節點進行更新。如果同時更新則會按照您在數據同步作業中配置的沖突修復策略進行響應。
DTS通過沖突檢測和修復最大程度地維護雙向同步實例的穩定性。目前DTS支持進行檢測的沖突類型包括:
INSERT導致的唯一性沖突
同步INSERT語句時違背了唯一性約束,例如雙向同步的兩個節點同時或者在極為接近的時間INSERT某個主鍵值相同的記錄,那么同步到對端時,會因為已經存在相同主鍵值的記錄,導致Insert同步失敗。
UPDATE更新的記錄不完全匹配
UPDATE要更新的記錄在同步目標實例中不存在時,DTS會自動轉化為INSERT,此時可能會出現唯一鍵的唯一性沖突。
UPDATE要更新的記錄出現主鍵或唯一鍵沖突。
DELETE對應的記錄不存在
DELETE要刪除的記錄在同步的目標實例中不存在。出現這種沖突時,不論配置何種沖突修復策略,DTS都會自動忽略DELETE操作。
由于數據同步兩端的系統時間可能存在差異、同步存在延時等多種因素,DTS無法完全保證沖突檢測機制能夠完全防止數據的沖突。在使用雙向同步時,您需要在業務層面配合進行相應的改造,保證同一個主鍵、業務主鍵或唯一鍵的記錄只在雙向同步的某個節點進行更新。
對于上述數據同步的沖突,DTS提供了修復策略,您可以在配置雙向同步時選擇。
支持同步的SQL
操作類型 | SQL操作語句 |
DML | INSERT、UPDATE、DELETE |
DDL |
|
僅正向任務(即源庫同步至目標庫)支持同步DDL,反向任務(即目標庫同步至源庫)不支持同步DDL,將自動過濾DDL操作。
數據庫賬號的權限要求
數據庫 | 所需權限 | 創建及授權方式 |
源RDS MySQL | 高權限賬號 | |
目標RDS MySQL |
操作步驟
進入目標地域的同步任務列表頁面(二選一)。
通過DTS控制臺進入
登錄數據傳輸服務DTS控制臺。
在左側導航欄,單擊數據同步。
在頁面左上角,選擇同步實例所屬地域。
通過DMS控制臺進入
說明實際操作可能會因DMS的模式和布局不同,而有所差異。更多信息,請參見極簡模式控制臺和自定義DMS界面布局與樣式。
登錄DMS數據管理服務。
在頂部菜單欄中,選擇
。在同步任務右側,選擇同步實例所屬地域。
單擊創建任務,進入任務配置頁面。
可選:在頁面右上角,單擊試用新版配置頁。
說明若您已進入新版配置頁(頁面右上角的按鈕為返回舊版配置頁),則無需執行此操作。
新版配置頁和舊版配置頁部分參數有差異,建議使用新版配置頁。
配置源庫及目標庫信息。
警告選擇源和目標實例后,建議您仔細閱讀頁面上方顯示的使用限制,否則可能會導致任務失敗或數據不一致。
類別
配置
說明
無
任務名稱
DTS會自動生成一個任務名稱,建議配置具有業務意義的名稱(無唯一性要求),便于后續識別。
源庫信息
選擇DMS數據庫實例
本示例無需選擇,輸入下方的數據庫信息即可。
數據庫類型
選擇MySQL。
接入方式
選擇云實例。
實例地區
選擇源RDS MySQL實例所屬地域。
是否跨阿里云賬號
本示例使用當前阿里云賬號下的數據庫實例,需選擇不跨賬號。
RDS實例ID
選擇源RDS MySQL實例ID。
說明源和目標RDS MySQL實例可以不同或相同,即您可以使用DTS實現兩個RDS MySQL實例間的數據遷移或同一RDS MySQL實例內的數據遷移。
數據庫賬號
填入源RDS MySQL實例的高權限賬號。
數據庫密碼
填入該數據庫賬號對應的密碼。
連接方式
根據需求選擇非加密連接或SSL安全連接。如果設置為SSL安全連接,您需要提前開啟RDS MySQL實例的SSL加密功能,詳情請參見使用云端證書快速開啟SSL鏈路加密。
目標庫信息
選擇DMS數據庫實例
本示例無需選擇,輸入下方的數據庫信息即可。
數據庫類型
選擇MySQL。
接入方式
選擇云實例。
實例地區
選擇目標RDS MySQL實例所屬地域。
是否跨阿里云賬號
本示例使用當前阿里云賬號下的數據庫實例,需選擇不跨賬號。
RDS實例ID
選擇目標RDS MySQL實例ID。
數據庫賬號
填入目標RDS MySQL實例的高權限賬號。
數據庫密碼
填入該數據庫賬號對應的密碼。
連接方式
根據需求選擇非加密連接或SSL安全連接。如果設置為SSL安全連接,您需要提前開啟RDS MySQL實例的SSL加密功能,詳情請參見使用云端證書快速開啟SSL鏈路加密。
配置完成后,單擊頁面下方的測試連接以進行下一步。
如果源或目標數據庫是阿里云數據庫實例(例如RDS MySQL、云數據庫MongoDB版等),DTS會自動將對應地區DTS服務的IP地址添加到阿里云數據庫實例的白名單中;如果源或目標數據庫是ECS上的自建數據庫,DTS會自動將對應地區DTS服務的IP地址添加到ECS的安全規則中,您還需確保自建數據庫沒有限制ECS的訪問(若數據庫是集群部署在多個ECS實例,您需要手動將DTS服務對應地區的IP地址添加到其余每個ECS的安全規則中);如果源或目標數據庫是IDC自建數據庫或其他云數據庫,則需要您手動添加對應地區DTS服務的IP地址,以允許來自DTS服務器的訪問。DTS服務的IP地址,請參見DTS服務器的IP地址段。
警告DTS自動添加或您手動添加DTS服務的公網IP地址段可能會存在安全風險,一旦使用本產品代表您已理解和確認其中可能存在的安全風險,并且需要您做好基本的安全防護,包括但不限于加強賬號密碼強度防范、限制各網段開放的端口號、內部各API使用鑒權方式通信、定期檢查并限制不需要的網段,或者使用通過內網(專線/VPN網關/智能網關)的方式接入。
配置任務對象。
在對象配置頁面,配置待同步的對象。
配置
說明
同步類型
固定選中增量同步。默認情況下,您還需要同時選中庫表結構同步和全量同步。預檢查完成后,DTS會將源實例中待同步對象的全量數據在目標集群中初始化,作為后續增量同步數據的基線數據。
源庫觸發器遷移方式
請根據實際情況選擇同步觸發器的方式,若您待同步的對象不涉及觸發器,則無需配置。更多信息,請參見配置同步或遷移觸發器的方式。
說明僅當同步類型選擇了庫表結構同步時才可以配置。
開啟遷移評估
評估源庫和目標庫的結構(如索引長度、存儲過程、依賴的表等)是否滿足要求,您可以根據實際情況選擇是或者否。
說明僅當同步類型選擇了庫表結構同步時才可以配置。
若選擇是,則可能會增加預檢查時間。您可以在預檢查階段查看評估結果,評估結果不影響預檢查結果。
同步拓撲
選擇雙向同步。
是否開啟Exactly-Once寫入
若待同步的對象中包含不具備主鍵和唯一約束的表,請選擇是。更多信息,請參見同步無主鍵和唯一約束的表。
是否過濾DDL
選擇為是:不同步DDL操作。
選擇為否:同步DDL操作。
重要為保障雙向同步鏈路的穩定性,僅正向任務(即源庫同步至目標庫)支持選擇是否同步DDL,反向任務(即目標庫同步至源庫)將自動過濾DDL操作。
全局沖突修復策略
如遇到以上沖突類型,根據業務需要,選擇合適的沖突修復策略。
TaskFailed(遇到沖突,任務報錯退出)
當數據同步遇到沖突時,同步任務直接報錯并退出,同步任務進入失敗狀態,需要您介入修復任務。
Ignore(遇到沖突,直接使用目標實例中的沖突記錄)
當數據同步遇到沖突時,直接跳過當前同步語句,繼續往下執行,選擇使用目標庫中的沖突記錄。
Overwrite(遇到沖突,直接覆蓋目標實例中的沖突記錄)
當數據同步遇到沖突時,直接覆蓋目標庫中的沖突記錄。
說明如果同步任務暫停或者重啟后存在延遲,在延遲期間,這些策略均不生效,默認覆蓋目標端數據。
目標已存在表的處理模式
預檢查并報錯攔截:檢查目標數據庫中是否有同名的表。如果目標數據庫中沒有同名的表,則通過該檢查項目;如果目標數據庫中有同名的表,則在預檢查階段提示錯誤,數據同步任務不會被啟動。
說明如果目標庫中同名的表不方便刪除或重命名,您可以更改該表在目標庫中的名稱,請參見庫表列名映射。
忽略報錯并繼續執行:跳過目標數據庫中是否有同名表的檢查項。
警告選擇為忽略報錯并繼續執行,可能導致數據不一致,給業務帶來風險,例如:
表結構一致的情況下,如在目標庫遇到與源庫主鍵或唯一鍵的值相同的記錄:
全量期間,DTS會保留目標集群中的該條記錄,即源庫中的該條記錄不會同步至目標數據庫中。
增量期間,DTS不會保留目標集群中的該條記錄,即源庫中的該條記錄會覆蓋至目標數據庫中。
表結構不一致的情況下,可能會導致無法初始化數據、只能同步部分列的數據或同步失敗,請謹慎操作。
是否遷移Event
請根據實際情況選擇是否同步源庫中的事件(Event)。若您選擇是,則還需遵循相關要求并進行后續操作。更多信息,請參見同步或遷移事件。
目標庫對象名稱大小寫策略
您可以配置目標實例中同步對象的庫名、表名和列名的英文大小寫策略。默認情況下選擇DTS默認策略,您也可以選擇與源庫、目標庫默認策略保持一致。更多信息,請參見目標庫對象名稱大小寫策略。
源庫對象
在源庫對象框中單擊待同步對象,然后單擊將其移動至已選擇對象框。
說明同步對象選擇的粒度為庫、表、列。若選擇的同步對象為表或列,其他對象(如視圖、觸發器、存儲過程)不會被同步至目標庫。
已選擇對象
如需更改單個同步對象在目標實例中的名稱,請右擊已選擇對象中的同步對象,設置方式,請參見庫表列名單個映射。
如需批量更改同步對象在目標實例中的名稱,請單擊已選擇對象方框右上方的批量編輯,設置方式,請參見庫表列名批量映射。
說明如需按庫或表級別選擇同步的SQL操作,請在已選擇對象中右擊待同步對象,并在彈出的對話框中選擇所需同步的SQL操作。支持的操作,請參見支持同步的SQL。
如需設置WHERE條件過濾數據,請在已選擇對象中右擊待同步的表,在彈出的對話框中設置過濾條件。設置方法請參見設置過濾條件。
如果使用了對象名映射功能,可能會導致依賴這個對象的其他對象同步失敗。
若您需要為增量同步配置獨立沖突修復策略。更多信息,請參見設置獨立沖突修復策略。
單擊下一步高級配置,進行高級參數配置。
配置
說明
選擇調度該任務的專屬集群
DTS默認將任務調度到共享集群上,您無需選擇。若您希望任務更加穩定,可以購買專屬集群來運行DTS同步任務。更多信息,請參見什么是DTS專屬集群。
復制源表Online DDL工具執行過程的臨時表到目標庫
若源庫使用數據管理DMS(Data Management)或gh-ost執行Online DDL變更,您可以選擇是否同步Online DDL變更產生的臨時表數據。
重要DTS任務暫不支持使用pt-online-schema-change等類似工具執行Online DDL變更,否則會導致DTS任務失敗。
是:同步Online DDL變更產生的臨時表數據。
說明Online DDL變更產生的臨時表數據過大,可能會導致同步任務延遲。
否,適配DMS Online DDL:不同步Online DDL變更產生的臨時表數據,只同步源庫使用數據管理DMS(Data Management)執行的原始DDL語句。
說明該方案會導致目標庫鎖表。
否,適配gh-ost:不同步Online DDL變更產生的臨時表數據,只同步源庫使用gh-ost執行的原始DDL語句,同時您可以使用默認的或者自行配置gh-ost影子表和無用表的正則表達式。
說明該方案會導致目標庫鎖表。
是否遷移賬號
請根據實際情況選擇是否同步源庫的賬號信息。若您選擇是,您還需要選擇待同步的賬號并確認賬號權限。授權方式等信息,請參見遷移數據庫賬號。
源庫、目標庫無法連接后的重試時間
在同步任務啟動后,若源庫或目標庫連接失敗則DTS會報錯,并會立即進行持續的重試連接,默認持續重試時間為720分鐘,您也可以在取值范圍(10~1440分鐘)內自定義重試時間,建議設置30分鐘以上。如果DTS在設置的重試時間內重新連接上源庫、目標庫,同步任務將自動恢復。否則,同步任務將會失敗。
說明針對同源或者同目標的多個DTS實例,如DTS實例A和DTS實例B,設置網絡重試時間時A設置30分鐘,B設置60分鐘,則重試時間以低的30分鐘為準。
由于連接重試期間,DTS將收取任務運行費用,建議您根據業務需要自定義重試時間,或者在源和目標庫實例釋放后盡快釋放DTS實例。
源庫、目標庫出現其他問題后的重試時間
在同步任務啟動后,若源庫或目標庫出現非連接性的其他問題(如DDL或DML執行異常),則DTS會報錯并會立即進行持續的重試操作,默認持續重試時間為10分鐘,您也可以在取值范圍(1~1440分鐘)內自定義重試時間,建議設置10分鐘以上。如果DTS在設置的重試時間內相關操作執行成功,同步任務將自動恢復。否則,同步任務將會失敗。
重要源庫、目標庫出現其他問題后的重試時間的值需要小于源庫、目標庫無法連接后的重試時間的值。
是否限制全量遷移速率
在全量同步階段,DTS將占用源庫和目標庫一定的讀寫資源,可能會導致數據庫的負載上升。您可以根據實際情況,選擇是否對全量同步任務進行限速設置(設置每秒查詢源庫的速率QPS、每秒全量遷移的行數RPS和每秒全量遷移的數據量(MB)BPS),以緩解目標庫的壓力。
說明僅當同步類型選擇了全量同步時才可以配置。
是否限制增量同步速率
您也可以根據實際情況,選擇是否對增量同步任務進行限速設置(設置每秒增量同步的行數RPS和每秒增量同步的數據量(MB)BPS),以緩解目標庫的壓力。
環境標簽
您可以根據實際情況,選擇用于標識實例的環境標簽。本示例無需選擇。
是否去除正反向任務的心跳表sql
根據業務需求選擇是否在DTS實例運行時,在源庫中寫入心跳SQL信息。
是:不在源庫中寫入心跳SQL信息,DTS實例可能會顯示有延遲。
否:在源庫中寫入心跳SQL信息,可能會影響源庫的物理備份和克隆等功能。
配置ETL功能
選擇是否配置ETL功能。關于ETL的更多信息,請參見什么是ETL。
是:配置ETL功能,并在文本框中填寫數據處理語句,詳情請參見在DTS遷移或同步任務中配置ETL。
否:不配置ETL功能。
監控告警
是否設置告警,當同步失敗或延遲超過閾值后,將通知告警聯系人。
不設置:不設置告警。
設置:設置告警,您還需要設置告警閾值和告警聯系人。更多信息,請參見在配置任務過程中配置監控告警。
單擊下一步數據校驗,進行數據校驗任務配置。
若您需要使用數據校驗功能,配置方法請參見配置數據校驗。
保存任務并進行預檢查。
若您需要查看調用API接口配置該實例時的參數信息,請將鼠標光標移動至下一步保存任務并預檢查按鈕上,然后單擊氣泡中的預覽OpenAPI參數。
若您無需查看或已完成查看API參數,請單擊頁面下方的下一步保存任務并預檢查。
說明在同步作業正式啟動之前,會先進行預檢查。只有預檢查通過后,才能成功啟動同步作業。
如果預檢查失敗,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。
如果預檢查產生警告:
對于不可以忽略的檢查項,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。
對于可以忽略無需修復的檢查項,您可以依次單擊點擊確認告警詳情、確認屏蔽、確定、重新進行預檢查,跳過告警檢查項重新進行預檢查。如果選擇屏蔽告警檢查項,可能會導致數據不一致等問題,給業務帶來風險。
購買實例。
預檢查通過率顯示為100%時,單擊下一步購買。
在購買頁面,選擇數據同步實例的計費方式、鏈路規格,詳細說明請參見下表。
類別
參數
說明
信息配置
計費方式
預付費(包年包月):在新建實例時支付費用。適合長期需求,價格比按量付費更實惠,且購買時長越長,折扣越多。
后付費(按量付費):按小時扣費。適合短期需求,用完可立即釋放實例,節省費用。
資源組配置
實例所屬的資源組,默認為default resource group。更多信息,請參見什么是資源管理。
鏈路規格
DTS為您提供了不同性能的同步規格,同步鏈路規格的不同會影響同步速率,您可以根據業務場景進行選擇。更多信息,請參見數據同步鏈路規格說明。
同步拓撲
固定為雙向同步。
訂購時長
在預付費模式下,選擇包年包月實例的時長和數量,包月可選擇1~9個月,包年可選擇1年、2年、3年和5年。
說明該選項僅在付費類型為預付費時出現。
配置完成后,閱讀并勾選《數據傳輸(按量付費)服務條款》。
單擊購買并啟動,并在彈出的確認對話框,單擊確定。
您可在數據同步界面查看具體任務進度。
配置反向同步任務。
等待正向同步任務同步初始化完成,直至運行狀態處于運行中。
定位至反向同步任務,單擊配置任務。
- 重要
配置反向同步任務時,您需要選擇正確的源和目標實例。反向同步中源實例為正向同步中的目標實例,目標實例為正向同步中的源實例,并且您還需仔細確認實例信息(如數據庫名稱、賬號、密碼)的一致性。
反向同步任務源和目標庫的實例地區不支持修改,且需要配置的參數比正向同步任務少,請以控制臺界面為準。
反向同步任務的目標已存在表的處理模式配置不檢測正向同步任務同步至目標實例中的表。
反向同步任務不支持同步正向任務已選擇對象中的對象。
反向任務配置時不建議您使用映射功能,否則會存在數據不一致的風險。
預檢查通過率顯示為100%時,單擊返回列表。
反向同步任務配置完成后,等待兩個同步任務的運行狀態均處于運行中,即完成雙向數據同步的配置流程。
設置獨立沖突修復策略
僅增量同步支持獨立沖突修復策略。
若雙向同步實例未設置獨立沖突修復策略,則在修改同步對象時不支持設置獨立沖突修復策略。
在已選擇對象中右鍵單擊待同步的庫或表。
開啟獨立沖突修復策略。
庫級別
在彈出的對話框的獨立沖突修復策略區域,將是否開啟獨立沖突解決策略選擇為是。
選擇沖突修復策略。
TaskFailed
當數據同步遇到沖突時,同步任務直接報錯并退出,同步任務進入失敗狀態,需要您介入修復任務。
Ignore
當數據同步遇到沖突時,直接跳過當前同步語句,繼續往下執行,選擇使用目標庫中的沖突記錄。
Overwrite
當數據同步遇到沖突時,直接覆蓋目標庫中的沖突記錄。
UseMax
當數據同步遇到沖突時,對當前沖突列的兩條記錄進行對比,將較大值的記錄寫入到目標庫中。若目標記錄不存在或字段類型不滿足要求,則系統的處理方法等效于Overwrite。
UseMin
當數據同步遇到沖突時,對當前沖突列的兩條記錄進行對比,將較小值的記錄寫入到目標庫中。若目標記錄不存在或字段類型不滿足要求,則系統的處理方法等效于Ignore。
在列名稱文本框中,輸入需要設置獨立沖突修復策略的列名。
說明若目標列的名稱使用了映射功能,則需要填入映射后的列名。
您可以單擊沖突檢測列右側的添加列,添加更多需要設置獨立沖突修復策略的列。
表級別
在彈出的對話框中的列區域,選中獨立沖突修復策略。
在沖突檢測列列,勾選需要設置獨立沖突修復策略的列。
說明默認已勾選主鍵和唯一約束的列。
設置了獨立沖突修復策略的列,全局沖突修復策略對其不生效。
選擇沖突修復策略。
說明若沖突檢測列為系統自動勾選的列,則不支持選擇UseMax和UseMin。
TaskFailed
當數據同步遇到沖突時,同步任務直接報錯并退出,同步任務進入失敗狀態,需要您介入修復任務。
Ignore
當數據同步遇到沖突時,直接跳過當前同步語句,繼續往下執行,選擇使用目標庫中的沖突記錄。
Overwrite
當數據同步遇到沖突時,直接覆蓋目標庫中的沖突記錄。
UseMax
當數據同步遇到沖突時,對當前沖突列的兩條記錄進行對比,將較大值的記錄寫入到目標庫中。若目標記錄不存在或字段類型不滿足要求,則系統的處理方法等效于Overwrite。
UseMin
當數據同步遇到沖突時,對當前沖突列的兩條記錄進行對比,將較小值的記錄寫入到目標庫中。若目標記錄不存在或字段類型不滿足要求,則系統的處理方法等效于Ignore。
單擊確定。