本文中含有需要您注意的重要提示信息，忽略該信息可能對您的業務造成影響，請務必仔細閱讀。
通過數據訂閱功能，您可以實時訂閱源庫的增量數據，輕松幫助業務實現輕量級緩存更新、業務異步解耦、含ETL邏輯的數據實時同步等場景。本文為您介紹如何創建Oracle數據訂閱任務。
前提條件
自建Oracle數據庫的版本為9i、10g、11g版本，暫不支持為RAC或PDB實例。
自建Oracle數據庫已開啟Supplemental Logging，且要求supplemental_log_data_pk，supplemental_log_data_ui已開啟，詳情請參見Supplemental Logging。
自建Oracle數據庫已開啟ARCHIVELOG（歸檔模式），設置合理的歸檔日志保持周期且歸檔日志能夠被訪問，詳情請參見ARCHIVELOG。
若源庫為經典網絡的實例，則不支持通過公網IP方式進行數據訂閱。
注意事項
類型 | 說明 |
源庫限制 |
|
其他限制 |
|
準備工作
登錄待訂閱的Oracle數據庫，創建用于數據訂閱的數據庫賬號并授予DBA權限。授權方式，請參見CREATE USER和GRANT USER。
如需訂閱增量數據，且不允許授予DBA權限，您需要按照如下方法開啟歸檔和補充日志，并為Oracle數據庫賬號授予更精細化的權限。
開啟歸檔和補充日志。
日志類型
開啟步驟
歸檔日志
執行如下命令，開啟歸檔日志：
shutdown immediate; startup mount; alter database archivelog; alter database open; archive log list;補充日志
按業務需求，選擇開啟庫級別補充日志或者表級別補充日志：
說明開啟庫級別補充日志，則DTS任務運行更為穩定；開啟表級別補充日志，則更節約源Oracle數據庫的磁盤空間。
開啟庫級別補充日志
打開最小補充日志：
alter database add supplemental log data;開啟庫級主鍵、唯一鍵補充日志：
alter database add supplemental log data (primary key,unique index) columns;
開啟表級補充日志
打開最小補充日志：
alter database add supplemental log data;開啟表級補充日志（兩者選其一） ：
開啟表級別主鍵補充日志
alter table table_name add supplemental log data (primary key) columns;開啟表級別全字段補充日志
alter table tb_name add supplemental log data (all) columns ;
為Oracle數據庫賬號授予更精細化的權限。
Oracle 9i～11g版本
#創建數據庫賬號（以rdsdt_dtsacct為例）并進行授權 create user rdsdt_dtsacct IDENTIFIED BY rdsdt_dtsacct; grant create session to rdsdt_dtsacct; grant connect to rdsdt_dtsacct; grant resource to rdsdt_dtsacct; grant execute on sys.dbms_logmnr to rdsdt_dtsacct; grant select on V_$LOGMNR_LOGS to rdsdt_dtsacct; grant select on all_objects to rdsdt_dtsacct; grant select on all_tab_cols to rdsdt_dtsacct; grant select on dba_registry to rdsdt_dtsacct; grant select any table to rdsdt_dtsacct; grant select any transaction to rdsdt_dtsacct; -- v$log privileges grant select on v_$log to rdsdt_dtsacct; -- v$logfile privileges grant select on v_$logfile to rdsdt_dtsacct; -- v$archived_log privileges grant select on v_$archived_log to rdsdt_dtsacct; -- v$parameter privileges grant select on v_$parameter to rdsdt_dtsacct; -- v$database privileges grant select on v_$database to rdsdt_dtsacct; -- v$active_instances privileges grant select on v_$active_instances to rdsdt_dtsacct; -- v$instance privileges grant select on v_$instance to rdsdt_dtsacct; -- v$logmnr_contents privileges grant select on v_$logmnr_contents to rdsdt_dtsacct; -- system tables grant select on sys.USER$ to rdsdt_dtsacct; grant select on SYS.OBJ$ to rdsdt_dtsacct; grant select on SYS.COL$ to rdsdt_dtsacct; grant select on SYS.IND$ to rdsdt_dtsacct; grant select on SYS.ICOL$ to rdsdt_dtsacct; grant select on SYS.CDEF$ to rdsdt_dtsacct; grant select on SYS.CCOL$ to rdsdt_dtsacct; grant select on SYS.TABPART$ to rdsdt_dtsacct; grant select on SYS.TABSUBPART$ to rdsdt_dtsacct; grant select on SYS.TABCOMPART$ to rdsdt_dtsacct;
操作步驟
進入訂閱任務的列表頁面。
登錄DMS數據管理服務。
在頂部菜單欄中，單擊集成與開發。
在左側導航欄，選擇。
說明實際操作可能會因DMS的模式和布局不同，而有所差異。更多信息，請參見極簡模式控制臺和自定義DMS界面布局與樣式。
您也可以登錄新版DTS訂閱任務的列表頁面。
在訂閱任務右側，選擇訂閱實例所屬地域。
說明新版DTS訂閱任務列表頁面，需要在頁面左上角工作臺的右側，選擇訂閱實例所屬地域。
單擊創建任務，配置源庫信息以及消費網絡類型。
警告選擇源實例后，建議您仔細閱讀頁面上方顯示的使用限制，否則可能會導致任務失敗或無法消費訂閱數據。
類別
配置
說明
無
任務名稱
DTS會自動生成一個訂閱名稱，建議配置具有業務意義的名稱（無唯一性要求），便于后續識別。
源庫信息
選擇已有的DMS數據庫實例（可選，如未創建可忽略此處選擇，直接在下方配置數據庫信息即可）
您可以按實際需求，選擇是否使用已有實例。
如使用已有實例，數據庫信息將自動填入，您無需重復輸入。
如不使用已有實例，您需要輸入下方的數據庫信息。
數據庫類型
選擇Oracle。
接入方式
根據源實例的類型進行選擇，本文以ECS自建數據庫為例介紹配置流程。
說明當實例為自建數據庫時，您還需要執行相應的準備工作，詳情請參見準備工作概覽。
實例地區
選擇自建Oracle數據庫所屬地域。
ECS實例ID
選擇自建Oracle數據庫所屬ECS實例ID。
端口號
填入自建Oracle數據庫的服務端口，默認為1521。
Oracle類型
非RAC實例：選擇該項后，您還需要填寫SID信息。
RAC或PDB實例：選擇該項后，您還需要填寫ServiceName信息。
重要暫不支持為RAC或PDB實例。
本示例選擇為非RAC實例。
數據庫賬號
填入自建Oracle的數據庫賬號，權限要求，請參見準備工作。
數據庫密碼
填入該數據庫賬號對應的密碼。
消費網絡類型
網絡類型
數據訂閱實例的網絡類型固定為專有網絡，您需要選擇具體的專有網絡和虛擬交換機。更多信息請參見專有網絡。
說明任務創建成功后，消費網絡類型不可更改。
若您的數據訂閱客戶端部署在專有網絡上，則建議選擇與客戶端一致的專有網絡和虛擬交換機。
通過內網地址進行數據訂閱時，網絡延遲最小。
配置完成后，單擊頁面右下角的測試連接以進行下一步。
如果源數據庫是阿里云數據庫實例（例如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默認將任務調度到共享集群上，您無需選擇。您可以購買指定規格的專屬集群來運行DTS訂閱任務，詳情請參見什么是DTS專屬集群。
源庫、目標庫無法連接后的重試時間
在訂閱任務連接失敗時，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在設置的重試時間內相關操作執行成功，訂閱任務將自動恢復。否則，訂閱任務將會失敗。
重要源庫、目標庫出現其他問題后的重試時間的值需要小于源庫、目標庫無法連接后的重試時間的值。
環境標簽
您可以根據實際情況，選擇用于標識實例的環境標簽。本示例無需選擇。
監控告警
是否設置告警，當訂閱失敗或延遲超過閾值后，將通知告警聯系人。
不設置：不設置告警。
設置：設置告警，您還需要設置告警閾值和告警聯系人。更多信息，請參見在配置任務過程中配置監控告警。
上述配置完成后，單擊頁面右下角的下一步保存任務并預檢查。
您可以將鼠標光標移動至下一步保存任務并預檢查按鈕上，然后單擊氣泡中的預覽OpenAPI調用，查看調用API接口配置該實例時的參數信息。
說明在訂閱任務正式啟動之前，會先進行預檢查。只有預檢查通過后，才能成功啟動訂閱任務。
如果預檢查失敗，請單擊失敗檢查項后的查看詳情，并根據提示修復后重新進行預檢查。
如果預檢查產生警告：
對于不可以忽略的檢查項，請單擊失敗檢查項后的查看詳情，并根據提示修復后重新進行預檢查。
對于可以忽略無需修復的檢查項，您可以依次單擊點擊確認告警詳情、確認屏蔽、確定、重新進行預檢查，跳過告警檢查項重新進行預檢查。如果選擇屏蔽告警檢查項，可能會導致數據不一致等問題，給業務帶來風險。
預檢查通過率顯示為100%時，單擊下一步購買。
在購買頁面，選擇數據訂閱實例的計費方式，詳細說明請參見下表。
參數
說明
計費方式
預付費（包年包月）：在新建實例時支付費用。適合長期需求，價格比按量付費更實惠，且購買時長越長，折扣越多。
后付費（按量付費）：按小時扣費。適合短期需求，用完可立即釋放實例，節省費用。
資源組配置
實例所屬的資源組，默認為default resource group。更多信息，請參見什么是資源管理。
訂閱時長
在預付費模式下，選擇包年包月實例的時長和數量，包月可選擇1~9個月，包年可選擇1年、2年、3年和5年。
說明該選項僅在付費類型為預付費時出現。
配置完成后，閱讀并勾選《數據傳輸（按量付費）服務條款》。
單擊購買并啟動，訂閱任務正式開始，您可在任務列表查看具體任務進度。
后續步驟
成功運行訂閱任務后，您需要新增消費組，并根據下游客戶端選擇訂閱數據的消費方式。
消費組的創建和管理，請參見新增消費組。
根據消費客戶端的類型，選擇訂閱數據的消費方式：