使用逻辑解码把文件输出为JSON格式_云数据库 RDS(RDS)-阿里云帮助中心

RDS PostgreSQL提供wal2json插件，可以将逻辑日志文件输出为JSON格式供您查看。

您可以加入RDS PostgreSQL插件交流钉钉群（103525002795），进行咨询、交流和反馈，获取更多关于插件的信息。

前提条件

实例为RDS PostgreSQL 10或以上版本。
说明
RDS PostgreSQL 16和17暂不支持该插件。
已设置实例参数wal_level = logical。详情请参见设置实例参数。

背景信息

wal2json是逻辑解码插件，使用该插件可以访问由INSERT和UPDATE生成的元组，解析WAL中的内容。

wal2json插件会在每个事务中生成一个JSON对象。JSON对象中提供了所有新/旧元组，额外选项还可以包括事务时间戳、限定架构、数据类型、事务ID等属性。详情请参见通过SQL获取JSON对象。

通过SQL获取JSON对象

通过DMS登录RDS数据库。

执行如下命令建表及初始化插件。

CREATE TABLE table2_with_pk (a SERIAL, b VARCHAR(30), c TIMESTAMP NOT NULL, PRIMARY KEY(a, c));
CREATE TABLE table2_without_pk (a SERIAL, b NUMERIC(5,2), c TEXT);

SELECT 'init' FROM pg_create_logical_replication_slot('test_slot', 'wal2json');

执行如下命令变更数据。

BEGIN;
INSERT INTO table2_with_pk (b, c) VALUES('Backup and Restore', now());
INSERT INTO table2_with_pk (b, c) VALUES('Tuning', now());
INSERT INTO table2_with_pk (b, c) VALUES('Replication', now());
DELETE FROM table2_with_pk WHERE a < 3;
INSERT INTO table2_without_pk (b, c) VALUES(2.34, 'Tapir');
UPDATE table2_without_pk SET c = 'Anta' WHERE c = 'Tapir';
COMMIT;

执行如下命令输出JSON格式的日志信息。

SELECT data FROM pg_logical_slot_get_changes('test_slot', NULL, NULL, 'pretty-print', '1');

解析日志

说明

如果需要停止输出并释放资源，请执行如下命令：

SELECT 'stop' FROM pg_drop_replication_slot('test_slot');