首批通过分布式安全可靠测评,为关键业务系统打造
obcdc 概述
更新时间:2025-11-17 14:05:26
CDC(Change Data Capture,即变更数据捕获)能够帮助您识别从上次提取之后发生变化的数据。您可用 CDC 提供的数据做历史库、近实时缓存、提供给消息队列(MQ),用户消费 MQ 做分析和审计等。
obcdc(OceanBase Change Data Capture,即 OceanBase 日志解析组件)以动态库的形式对外提供 OceanBase 数据库实时增量(事务)数据。
obcdc 通过 RPC 向 OceanBase 数据库请求各分区的 clog(Redo)日志,结合各个表、列的 schema 信息(通过 SQL 和 OBServer 节点交互获得),将 Redo 日志转化为一种中间数据格式(LOGMSG),聚合一个事务涉及的各分区的数据变更,以事务为单位逐行输出变更数据。
obcdc 的应用
obcdc 对外提供 OceanBase 数据库增量事务数据,调用 obcdc 的进程拿到数据后可用于数据同步和数据订阅。
数据同步:将 OceanBase 数据同步到同构或者异构的数据库,可以做逻辑迁移、逻辑备库、逻辑升级等;
数据订阅:将 OceanBase 数据同步给消息队列或数据仓库等,用于做实时计算、审计、监控等。
如何使用 obcdc 的详细介绍可参见 obcdc 开发说明。