PostgreSQL 逻辑解码输出插件（pgoutput、wal2json 与验证）

--- title: PostgreSQL 逻辑解码输出插件（pgoutput、wal2json 与验证） date: 2025-11-26 keywords: - 逻辑解码 - pgoutput - wal2json - 复制槽 - 流式输出 description: 配置PostgreSQL逻辑解码并选择输出插件（pgoutput/wal2json），创建复制槽与流式输出，提供验证方法确保事件正确与一致。 tags: - PostgreSQL - pgoutput - wal2json - 复制槽 - 数据与存储 - 数据库 - 流式输出 - 逻辑解码 categories: - 文章资讯 - 编程技术 --- ## 概述 逻辑解码将WAL中的变更解析为事件流。通过选择输出插件与复制槽，可将变更推送到下游或进行审计，支持表级选择与过滤。 ## 关键实践与参数 - 参数: `wal_level=logical` `max_replication_slots` `max_wal_senders` - 输出插件: `pgoutput` 官方或 `wal2json` JSON格式 - 复制槽: 持久化位点, 支持流式读取 - 表过滤: 选择性输出目标表 ## 示例/配置/实现 ```sql ALTER SYSTEM SET wal_level = 'logical'; ALTER SYSTEM SET max_replication_slots = 16; ALTER SYSTEM SET max_wal_senders = 16; SELECT pg_reload_conf(); ``` ```sql SELECT * FROM pg_create_logical_replication_slot('slot_json', 'wal2json'); ``` ```bash pg_recvlogical -d shop --slot=slot_json --start -f - --no-loop --plugin=wal2json ``` ```sql INSERT INTO orders(id, customer_id, amount) VALUES (1001, 42, 12.3); ``` ## 验证 - 插件输出: 变更以预期格式输出 - 位点管理: 复制槽位点前进且无积压 - 过滤正确: 仅目标表的事件被输出 - 一致性: 下游接收与重放一致无丢失 ## 注意事项 - 长时间未消费会导致WAL积压 - 插件选择需结合下游解析能力 - 权限与安全管理复制槽 - 在维护窗口进行大批量操作