本文中含有需要您注意的重要提示信息,忽略該信息可能對您的業務造成影響,請務必仔細閱讀。
通過數據訂閱功能,您可以實時訂閱源庫的增量數據,輕松幫助業務實現輕量級緩存更新、業務異步解耦、含ETL邏輯的數據實時同步等場景。本文為您介紹如何創建Oracle數據訂閱通道。
前提條件
自建Oracle數據庫的版本為9i、10g、11g版本,且不支持為RAC實例。
自建Oracle數據庫已開啟Supplemental Logging,且要求supplemental_log_data_pk,supplemental_log_data_ui已開啟,詳情請參見Supplemental Logging。
自建Oracle數據庫已開啟ARCHIVELOG(歸檔模式),設置合理的歸檔日志保持周期且歸檔日志能夠被訪問,詳情請參見ARCHIVELOG。
注意事項
- 由于使用gh-ost或pt-online-schema-change等類似工具執行在線DDL變更不會被訂閱到,客戶端在將消費到的數據寫入目標表時可能會因為表結構不一致而導致寫入失敗。
- 如果訂閱的源數據庫還處于其他任務中(例如該數據庫還存在于某個正在運行的數據遷移任務中),您可能會訂閱到訂閱對象以外的數據,此類場景中,您需要手動在訂閱客戶端中過濾掉不需要的數據。
準備工作
登錄待訂閱的Oracle數據庫,創建用于數據訂閱的數據庫賬號并授予DBA權限。
如需訂閱增量數據,且不允許授予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;
操作步驟
購買數據訂閱通道,詳情請參見購買流程。
說明購買時選擇訂閱實例類型為Oracle并選擇源實例所屬的地域。
登錄數據傳輸控制臺。
在左側導航欄,單擊數據訂閱。
在數據訂閱列表頁面上方,選擇訂閱通道所屬地域。
定位至已購買的數據訂閱通道,單擊配置訂閱通道。
配置數據訂閱的源庫信息和網絡類型。
類別
配置
說明
無
訂閱名稱
DTS會自動生成一個訂閱名稱,建議配置具有業務意義的名稱(無唯一性要求),便于后續識別。
源庫信息
實例類型
根據源實例的類型進行選擇,本文以ECS上的自建數據庫為例介紹配置流程。
說明當自建數據庫為其他實例類型時,您還需要執行相應的準備工作,詳情請參見準備工作概覽。
數據庫類型
固定為Oracle,不可變更。
實例地區
購買數據訂閱通道時選擇的源實例地域,不可變更。
ECS實例ID
選擇自建Oracle數據庫所屬的ECS實例ID。
端口
填入自建Oracle數據庫的服務端口。
SID
填入自建Oracle數據庫的SID信息。
數據庫賬號
填入自建Oracle的數據庫賬號。
說明創建及授權方法請參見準備工作。
數據庫密碼
填入該數據庫賬號對應的密碼。
消費網絡類型
無
設置數據訂閱實例所屬的網絡類型。
說明建議配置同部署數據訂閱客戶端的ECS實例屬于同一網絡。例如ECS是專有網絡,那么此處的網絡類型選擇為專有網絡并指定ECS所屬的專有網絡和虛擬交換機。
通過內網地址進行數據訂閱時,網絡延遲最小。
上述配置完成后,單擊授權白名單并進入下一步。
如果源數據庫是阿里云數據庫實例(例如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操作。
- 結構更新
訂閱整個實例所有對象的結構創建、刪除及修改,您需要使用數據訂閱客戶端過濾所需的數據。
說明- 如果選擇整個庫作為訂閱對象,那么該庫中新增對象的增量數據也可以被訂閱到。
- 如果選擇某個表作為訂閱對象,那么只有這個表的增量數據可以被訂閱到。此時如果需要加入一個新的表作為訂閱對象,您需要將其加入至訂閱對象中,詳情請參見修改訂閱對象。
訂閱對象 在訂閱對象框中將想要訂閱的對象選中,單擊圖標將其移動到已選擇對象框。
說明 訂閱對象支持選擇的粒度為庫、表。- 數據更新
上述配置完成后,單擊頁面右下角的保存并預檢查。
說明在訂閱任務正式啟動之前,會先進行預檢查。只有預檢查通過后,才能成功啟動訂閱任務。
如果預檢查失敗,單擊具體檢查項后的,查看失敗詳情。根據提示修復問題后,重新進行預檢查。
在預檢查對話框中顯示預檢查通過后,關閉預檢查對話框。
配置完成后,數據訂閱通道會進入初始化階段,該階段一般會持續1分鐘左右。初始化完成后即可進行新增消費組與消費訂閱數據的操作。