pgstream

pgstream 是一个用 Go 语言编写的实时 PostgreSQL WAL 读取器，能够捕获数据库中的 INSERT、UPDATE 和 DELETE 操作。它通过逻辑复制机制直接从 PostgreSQL 的写前日志（WAL）中读取数据变更，并将其转换为可读的 JSON 格式输出。该项目利用了 Postgres 内置的 pgoutput 插件来解码二进制 WAL 记录，并通过 LSN（日志序列号）跟踪每个事件的位置，确保数据变更的准确性和完整性。适用于需要实时监控和响应数据库变化的场景，如数据同步、审计日志生成或触发基于数据变更的业务流程。