CDC
更新時間 2025-02-05 09:37:29
最近更新時間: 2025-02-05 09:37:29
分享文章
CDC是一種用于捕獲，處理和同步TeleDB-X實例數據變化的工具，允許將實例中的變更數據實時地同步到下游系統。本頁為您介紹CDC的使用和管理操作。
初始化插件
通過pgxc_ctl新建一個雙CN、雙DN的實例，并開啟服務。
通過telesql連接到CN節點。
在配置文件中設置加載shared_preload_libraries。
創建插件
通過telesql連接到CN節點。
執行sql “create extension teledbx_cdc”
執行telesql命令\dx，查看插件teledbx_cdc是否存在。
執行sql “select teledbx_init_cdc_meta();”對元數據進行初始化。
管理cdc復制槽
執行以下語法在所有數據節點創建邏輯復制槽
select * from teledbx_create_logical_replication_slot('cdc_demo','teledbx_cdc');執行以下語法查看元數據
select * from teledbx.cdc_slot;執行以下語法刪除邏輯復制槽
select * from teledbx_drop_logical_replication_slot('cdc_demo');
讀取變更數據
執行以下語法對變更數據進行可重復讀，返回結果為text類型
select * from teledbx_cdc_peek_changes('slot_name', batch_count, optional-value);執行以下語法對變更數據進行可重復讀，返回結果為binary類型
select * from teledbx_cdc_peek_binary_changes('slot_name', batch_count, optional-value);執行以下語法推高邏輯復制槽位點
teledb=執行以下語法對變更數據進行不可重復讀，返回結果為text類型
select * from teledbx_cdc_get_changes('slot_name', batch_count, optional-value);執行以下語法對變更數據進行不可重復讀
select * from teledbx_cdc_get_binary_changes('slot_name', batch_count, optional-value);
