PostgreSQL逻辑解码将WAL日志转换为可读的变更流，支持数据同步、CDC、审计等场景。需配置wal_level=logical、创建复制槽并确保表有主键或REPLICA IDENTITY。通过输出插件（如wal2json）将解析结果转为JSON等格式，使用pg_logical_slot_get_changes()获取变更事件，实现异构系统间的数据实时同步与事件驱动架构。

PostgreSQL 的逻辑解码（Logical Decoding）是一种将数据库中的WAL（Write-Ahead Logging）日志从物理格式转换为可读的逻辑数据变更流的技术。它允许外部系统或应用消费这些变更事件，实现数据同步、复制、审计或构建事件驱动架构。

逻辑解码的基本原理

PostgreSQL 默认记录的是物理WAL日志，描述的是“页上哪个字节被修改了”，这类信息对人类和外部系统不友好。逻辑解码通过解析WAL，提取出“哪张表的哪行数据被插入/更新/删除”这样的语义信息。

其核心机制包括：

• 解析WAL条目：PostgreSQL 在事务提交时生成WAL记录，逻辑解码进程读取这些记录，并识别出涉及用户表的数据变更（DML操作）。
• 重构元组信息：对于UPDATE和DELETE操作，需要获取旧值（before image）；INSERT则提供新值（after image）。这依赖于表开启 REPLICA IDENTITY或全列日志（full模式）。
• 输出插件（Output Plugin）：逻辑解码本身不直接定义输出格式，而是通过插件（如test_decoding、wal2json等）将解析后的变更事件转换成指定格式（JSON、自定义文本等）。

启用逻辑解码的前提条件

要使用逻辑解码，必须在数据库配置中进行以下设置：

• wal_level = logical：这是最基本要求，确保WAL记录包含足够的逻辑信息（如行级变更前后镜像）。
• 开启复制槽（Replication Slot）：用于跟踪解码进度，防止WAL过早被清理。可通过SQL命令创建： SELECT pg_create_logical_replication_slot('slot_name', 'plugin_name');
• 表需支持行过滤：表必须有主键或定义了REPLICA IDENTITY，否则无法准确标识被修改的行。

如何使用逻辑解码获取变更数据

一旦配置完成，就可以通过流复制协议或SQL函数读取逻辑解码结果。

Expanso yaml-to-json

使用 Expanso Edge 管道将 YAML 输入转换为 JSON 格式。

下载

例如，使用pg_logical_slot_get_changes()函数获取某个复制槽的变更：

SELECT * FROM pg_logical_slot_get_changes('slot_name', NULL, NULL);

返回的结果会包含每一条DML操作的详细信息，具体格式取决于所使用的输出插件。

常见输出示例（以wal2json插件为例）：

{ "change": [ { "kind": "update", "schema": "public", "table": "users", "oldkeys": { "keynames": ["id"], "keyvalues": [101] }, "oldvalues": { "name": "Alice", "email": "alice@example.com" }, "newvalues": { "name": "Alicia", "email": "alicia@example.com" } } ] }

典型应用场景

逻辑解码广泛应用于以下场景：

• 异构数据同步：将PostgreSQL的数据变更实时推送到Elasticsearch、Kafka、Redis或其他数据库。
• CDC（Change Data Capture）：作为ETL流程的一部分，捕获并处理增量数据变化。
• 审计与监控：记录所有关键表的修改历史，用于合规性检查。
• 微服务间事件传递：基于数据变更触发业务事件，实现松耦合架构。

基本上就这些。只要配置正确，并选择合适的输出插件，PostgreSQL 逻辑解码就能稳定地提供细粒度的数据变更流。注意控制复制槽的使用，避免长期未消费导致WAL堆积影响性能。