wal2json

pig repo add pgdg -u          # 添加 PGDG 仓库并更新缓存

wal_level = logical
max_replication_slots = 10
max_wal_senders = 10

# 创建复制槽
pg_recvlogical -d postgres --slot test_slot --create-slot -P wal2json

# 开始消费变更
pg_recvlogical -d postgres --slot test_slot --start -o pretty-print=1 -f -

# 完成后删除槽
pg_recvlogical -d postgres --slot test_slot --drop-slot

-- 创建逻辑复制槽
SELECT * FROM pg_create_logical_replication_slot('test_slot', 'wal2json');

-- 查看变更（不消费）
SELECT data FROM pg_logical_slot_peek_changes('test_slot', NULL, NULL);

-- 获取并消费变更
SELECT data FROM pg_logical_slot_get_changes('test_slot', NULL, NULL,
    'pretty-print', '1');

-- 删除槽
SELECT pg_drop_replication_slot('test_slot');

{
  "change": [
    {
      "kind": "insert",
      "schema": "public",
      "table": "my_table",
      "columnnames": ["a", "b"],
      "columntypes": ["integer", "text"],
      "columnvalues": [1, "hello"]
    },
    {
      "kind": "delete",
      "schema": "public",
      "table": "my_table",
      "oldkeys": {
        "keynames": ["a"],
        "keytypes": ["integer"],
        "keyvalues": [1]
      }
    }
  ]
}