操作场景

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

前提条件

• 请确保您的实例内核大版本满足，本插件所支持的内核版本，请参考支持的版本插件列表。

注意事项

• wal2json插件默认自带，无需创建。

使用示例

-- 1.执行如下命令建表及初始化插件。
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');
  ​
-- 2.执行如下命令变更数据。
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;
  ​​
-- 3.执行如下命令输出JSON格式的日志信息。
SELECT data FROM pg_logical_slot_get_changes('test_slot', NULL, NULL, 'pretty-print', '1');