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);
