Postgres REPEATABLE READ事务中如何获取对应视角的LSN

问题核心原因 #

pg_current_wal_lsn()返回的是PostgreSQL实例全局的最新WAL写入位点，和当前事务的隔离级别、一致性视图完全无关，只要实例有其他写入操作，该值就会持续增长，因此无法匹配你要获取事务视角固定LSN的需求。

推荐解决方案（兼容所有支持逻辑复制的PostgreSQL版本） #

这是官方原生支持的「存量数据处理+增量同步」标准流程，完全避免手动匹配LSN的出错风险：

• 开启REPEATABLE READ事务，确保后续读取的所有存量数据都是事务启动时刻的一致性视图：

BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ;

• 在同一个事务内创建逻辑复制槽，复制槽会自动绑定当前事务的一致性视图，返回的consistent_point就是你需要的事务视角固定LSN：

SELECT slot_name, plugin, consistent_point 
FROM pg_create_logical_replication_slot(
    'your_custom_slot', -- 自定义复制槽名称
    'pgoutput', -- 可替换为wal2json、decoderbufs等其他逻辑解码插件
    false -- 设为false表示创建持久化复制槽，设为true为临时槽
);

• 在当前事务内完成所有存量数据的导出、处理操作，此时读取的所有数据都是consistent_point位点之前的已提交数据。
• 提交当前事务，后续直接使用已创建的复制槽从consistent_point开始消费增量数据即可，不会出现数据重复或丢失：所有存量处理过程中产生的新变更都会被复制槽捕获，且这些变更对应的事务都不会出现在你之前处理的存量数据中。

关于你担心的WAL段提前清理问题：只要复制槽创建完成，PostgreSQL会自动保留该复制槽consistent_point之后的所有WAL段，直到复制槽被删除，无需额外调整WAL保留参数。

可选方案（PostgreSQL 13及以上可用） #

如果你需要单独获取事务一致性视图对应的LSN而不提前创建复制槽，可以使用pg_current_snapshot_lsn()函数：

BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ;
-- 首次执行任意查询触发快照生成后，调用该函数即可拿到固定的事务视角LSN
SELECT pg_current_snapshot_lsn();

该值在REPEATABLE READ事务的整个生命周期内固定不变，和同事务内创建复制槽返回的consistent_point完全一致。

内容的提问来源于stack exchange，提问作者Adam Kamor