wal 提供数据库底层变更流，通过逻辑复制槽和逻辑解码实现高效 cdc；trigger 用于补充业务上下文，如记录操作用户、触发通知等。建议以 wal 为主通道同步数据至外部系统，同时用 trigger 处理审计和轻量级事件；推荐使用 debezium + kafka 或 wal2json 插件构建可靠变更捕获架构。
PostgreSQL 数据变更的实时捕获可以通过结合 WAL（Write-Ahead Logging） 和 触发器（Trigger） 实现，但两者角色不同，需合理搭配使用。WAL 提供数据库底层的变更流，而 Trigger 可用于在事务层执行自定义逻辑。下面介绍如何利用它们协同工作来实现高效、可靠的变更捕获。
1. 使用 WAL 实现变更数据捕获（CDC）
PostgreSQL 的 WAL 是实现 CDC 的核心机制，它记录了所有对数据文件的物理或逻辑修改。要实现实时捕获，推荐启用逻辑复制槽（Logical Replication Slots） 和使用逻辑解码（Logical Decoding） 插件。
步骤如下：
- 设置 wal_level = logical，这是开启逻辑解码的前提。
- 创建一个逻辑复制槽，用于持久化消费位置，防止 WAL 被过早清理。
- 使用 pg_logical_slot_get_changes() 或第三方工具如 Debezium、wal2json 插件来读取格式化的变更事件。
示例：启用 wal2json 输出变更
SELECT * FROM pg_logical_slot_get_changes('slot_name', NULL, NULL, 'format-version', '1', 'pretty-print', '1');这种方式能捕获 INSERT、UPDATE、DELETE 操作，并以 JSON 格式输出，适合对接 Kafka、消息队列等系统。
2. 使用 Trigger 补充业务级变更逻辑
虽然 WAL 能捕获所有变更，但它不支持附加上下文（如操作用户、应用信息）。Trigger 可在 DML 执行时插入额外信息到审计表或消息队列中。
常见用途包括：
- 记录谁在什么时候修改了哪些字段。
- 将变更推送到 notify 队列，通过 LISTEN/NOTIFY 通知外部程序。
- 填充轻量级变更日志表，供后续异步处理。
示例：创建触发器记录变更
CREATE TABLE audit_log ( id serial PRIMARY KEY, table_name text, operation text, old_data json, new_data json, changed_at timestamp, changed_by text ); <p>CREATE OR REPLACE FUNCTION log_change() RETURNS trigger AS $$ BEGIN IF (TG_OP = 'DELETE') THEN INSERT INTO audit_log VALUES (DEFAULT, TG_TABLE_NAME, 'DELETE', row_to_json(OLD), NULL, NOW(), CURRENT_USER); RETURN OLD; ELSIF (TG_OP = 'UPDATE') THEN INSERT INTO audit_log VALUES (DEFAULT, TG_TABLE_NAME, 'UPDATE', row_to_json(OLD), row_to_json(NEW), NOW(), CURRENT_USER); RETURN NEW; ELSIF (TG_OP = 'INSERT') THEN INSERT INTO audit_log VALUES (DEFAULT, TG_TABLE_NAME, 'INSERT', NULL, row_to_json(NEW), NOW(), CURRENT_USER); RETURN NEW; END IF; RETURN NULL; END; $$ LANGUAGE plpgsql;</p><p>CREATE TRIGGER user_change_trigger AFTER INSERT OR UPDATE OR DELETE ON users FOR EACH ROW EXECUTE FUNCTION log_change();
3. WAL 与 Trigger 结合使用的建议场景
单独使用 WAL 或 Trigger 都有局限，结合使用可兼顾性能与灵活性。
- 用 WAL 做主通道进行高吞吐 CDC，例如同步到数仓或搜索引擎。
- 用 Trigger 处理需要上下文的审计、权限校验或发送轻量通知。
- 避免在 Trigger 中做耗时操作，以免阻塞主事务。
- 若需精确顺序和不丢消息，优先依赖 WAL 流；Trigger 可作为辅助手段。
4. 工具推荐与架构设计
实际项目中，建议采用成熟方案降低复杂度：
- Debezium + Kafka Connect：基于 WAL 捕获变更，自动管理复制槽，支持多种数据格式。
- wal2json / pgoutput：选择合适的输出插件，wal2json 更适合调试，pgoutput 用于原生逻辑复制。
- pg_notify()：在 Trigger 中调用 PERFORM pg_notify('channel', payload)，让外部监听程序接收事件。
典型架构：数据库变更 → WAL 日志 → 逻辑解码插件 → 消息队列 → 消费服务。Trigger 同时写入本地审计表，用于合规查询。
基本上就这些。WAL 是实现实时 CDC 的基础，而 Trigger 提供精细化控制能力。合理组合二者，可以在保证性能的同时满足多样化的业务需求。
