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格式
• 复制槽: 持久化位点, 支持流式读取
• 表过滤: 选择性输出目标表

示例/配置/实现

ALTER SYSTEM SET wal_level = 'logical';
ALTER SYSTEM SET max_replication_slots = 16;
ALTER SYSTEM SET max_wal_senders = 16;
SELECT pg_reload_conf();

SELECT * FROM pg_create_logical_replication_slot('slot_json', 'wal2json');

pg_recvlogical -d shop --slot=slot_json --start -f - --no-loop --plugin=wal2json

INSERT INTO orders(id, customer_id, amount) VALUES (1001, 42, 12.3);

验证

• 插件输出: 变更以预期格式输出
• 位点管理: 复制槽位点前进且无积压
• 过滤正确: 仅目标表的事件被输出
• 一致性: 下游接收与重放一致无丢失

注意事项

• 长时间未消费会导致WAL积压
• 插件选择需结合下游解析能力
• 权限与安全管理复制槽
• 在维护窗口进行大批量操作