本文中含有需要您注意的重要提示信息,忽略該信息可能對您的業務造成影響,請務必仔細閱讀。
數據訂閱功能可以幫助您獲取數據庫的實時增量數據,您可以根據自身業務需求自由消費增量數據,并寫入任意目標端,適配各類業務場景,例如緩存更新、業務異步解耦、異構數據源數據實時同步及含復雜ETL的多種業務場景。本文將介紹在DTS專屬集群中如何創建RDS MySQL數據訂閱任務。
前提條件
已創建DTS專屬集群,創建方式,請參見創建DTS專屬集群。
已創建源RDS MySQL實例,創建方式,請參見快速創建RDS MySQL實例。
注意事項
類型 | 說明 |
源庫限制 |
|
其他限制 |
|
操作步驟
進入DTS專屬集群頁面。
在工作臺右側,選擇專屬集群所在地域。
說明若您登錄的是數據管理DMS控制臺,需要在集群任務右側,選擇專屬集群所在地域。
在目標專屬集群操作列,選擇 。
配置源庫信息和消費網絡類型。
警告選擇源實例后,建議您仔細閱讀頁面上方顯示的使用限制,否則可能會導致任務失敗或無法消費訂閱數據。
類別
配置
說明
任務名稱
無
DTS會自動生成一個訂閱名稱,建議配置具有業務意義的名稱(無唯一性要求),便于后續識別。
源庫信息
選擇已有連接信息
您可以按實際需求,選擇是否使用已有實例。
如使用已有實例,下方數據庫信息將自動填入,您無需重復輸入。
如不使用已有實例,您需要輸入下方的數據庫信息。
數據庫類型
選擇MySQL。
接入方式
選擇云實例。
實例地區
源RDS MySQL實例所屬地域。在創建專屬集群時已指定,不支持更改。
是否跨阿里云賬號
本示例選擇不跨賬號。
RDS實例ID
選擇RDS MySQL實例ID。
數據庫賬號
填入RDS MySQL數據庫的只讀賬號,或具備REPLICATION CLIENT、REPLICATION SLAVE、SHOW VIEW和SELECT權限的自定義賬號。
數據庫密碼
填入該數據庫賬號對應的密碼。
連接方式
根據需求選擇非加密連接或SSL安全連接。如果設置為SSL安全連接,您需要提前開啟RDS MySQL實例的SSL加密功能,詳情請參見設置SSL加密。
消費網絡類型
網絡類型
消費網絡類型目前僅支持專有網絡,請選擇對應的專有網絡和虛擬交換機。
說明網絡類型任務配置完成后不可修改,在消費訂閱的數據時要使用對應的網絡類型消費訂閱的數據。
配置完成后,單擊頁面右下角的測試連接以進行下一步。
如果源數據庫是阿里云數據庫實例(例如RDS MySQL、云數據庫MongoDB版等),DTS會自動將對應地區DTS服務的IP地址添加到阿里云數據庫實例的白名單;如果源數據庫是ECS上的自建數據庫,DTS會自動將對應地區DTS服務的IP地址添到ECS的安全規則中,您還需手動在ECS上的自建數據庫中添加對應地區DTS服務的IP地址,以允許來自DTS服務器的訪問;如果源數據庫是IDC自建數據庫或其他云數據庫,則需要您手動添加對應地區DTS服務的IP地址,以允許來自DTS服務器的訪問。DTS服務的IP地址,請參見DTS服務器的IP地址段。
警告DTS自動添加或您手動添加DTS服務的公網IP地址段可能會存在安全風險,一旦使用本產品代表您已理解和確認其中可能存在的安全風險,并且需要您做好基本的安全防護,包括但不限于加強賬號密碼強度防范、限制各網段開放的端口號、內部各API使用鑒權方式通信、定期檢查并限制不需要的網段,或者使用通過內網(專線/VPN網關/智能網關)的方式接入。
配置任務對象。
在對象配置頁面,配置待訂閱的對象。
配置
說明
需要訂閱的數據類型
需要訂閱的數據類型默認已勾選,且不支持修改。
數據更新
訂閱已選擇對象的增量數據更新,包含數據的INSERT、DELETE和UPDATE操作。
結構更新
訂閱整個實例所有對象的結構創建、刪除及修改,您需要使用數據訂閱客戶端過濾所需的數據。
源庫對象
從源庫對象列表中,選擇待訂閱對象,單擊圖標,將其移動到已選擇對象列表中。
說明訂閱對象支持選擇的粒度為庫、表。
如果選擇整個庫作為訂閱對象,那么該庫中新增對象的增量數據也可以被訂閱到。
如果選擇某個表作為訂閱對象,那么只有這個表的增量數據可以被訂閱到。此時如果需要加入一個新的表作為訂閱對象,您需要將其加入至訂閱對象中,詳情請參見修改訂閱對象。
單擊下一步高級配置,進行高級參數配置。
配置
說明
選擇調度該任務的專屬集群
固定為當前的專屬集群,且不支持修改。
源庫、目標庫無法連接后的重試時間
在訂閱任務連接失敗時,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在設置的重試時間內相關操作執行成功,訂閱任務將自動恢復。否則,訂閱任務將會失敗。
重要源庫、目標庫出現其他問題后的重試時間的值需要小于源庫、目標庫無法連接后的重試時間的值。
環境標簽
您可以根據實際情況,選擇用于標識實例的環境標簽。本示例無需選擇。
是否去除正反向任務的心跳表sql
根據業務需求選擇是否在DTS實例運行時,在源庫中寫入心跳SQL信息。
是:不在源庫中寫入心跳SQL信息,DTS實例可能會顯示有延遲。
否:在源庫中寫入心跳SQL信息,可能會影響源庫的物理備份和克隆等功能。
監控告警
是否設置告警,當訂閱失敗或延遲超過閾值后,將通知告警聯系人。
不設置:不設置告警。
設置:設置告警,您還需要設置告警閾值和告警聯系人。更多信息,請參見在配置任務過程中配置監控告警。
上述配置完成后,單擊頁面右下角的下一步保存任務并預檢查。
您可以將鼠標光標移動至下一步保存任務并預檢查按鈕上,然后單擊氣泡中的預覽OpenAPI調用,查看調用API接口配置該實例時的參數信息。
說明在訂閱任務正式啟動之前,會先進行預檢查。只有預檢查通過后,才能成功啟動訂閱任務。
如果預檢查失敗,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。
如果預檢查產生警告:
對于不可以忽略的檢查項,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。
對于可以忽略無需修復的檢查項,您可以依次單擊點擊確認告警詳情、確認屏蔽、確定、重新進行預檢查,跳過告警檢查項重新進行預檢查。如果選擇屏蔽告警檢查項,可能會導致數據不一致等問題,給業務帶來風險。
預檢查通過率顯示為100%時,單擊下一步-選擇DTS實例規格。
在信息配置區域配置任務的鏈路規格,最少配置1DU,最多配置剩余可用數。
配置完成后,閱讀并勾選《數據傳輸(按量付費)服務條款》。
單擊啟動任務,訂閱任務正式開始。
您可以在集群任務列表中篩選目標任務,并查看任務的進度。
后續步驟
成功運行訂閱任務后,您需要新增消費組,并根據下游客戶端選擇訂閱數據消費方式。
消費組的創建和管理,請參見新增消費組。
根據消費客戶端類型,選擇訂閱數據的消費方式: