在PostgreSQL 10中手动创建用于发布的复制槽

Question

pg_create_logical_replication_slot('my_slot', 'wal2json');

并使用pg_recvlogic或进行特殊的SQL查询连接到它。这允许您从json中的数据库中获取所有操作（如果您使用wal2json插件或类似的操作），然后对这些数据执行您想要的任何操作。

但是在PostgreSQL 10中，我们有发布/订阅机制，它只允许复制选定的表。这非常方便，因为许多无用的数据没有被发送。该过程如下所示：

首先，创建发布

CREATE PUBLICATION foo FOR TABLE herp, derp;

CREATE SUBSCRIPTION mysub CONNECTION <connection stuff> PUBLICATION foo;

正如我所提到的，create subscription查询正在后台的主数据库上创建一个复制槽，但是如何在没有订阅和第二个数据库的情况下手动创建一个复制槽呢？这里的文件说：

为此，单独创建复制槽（使用函数pg_create_logical_replication_slot，插件名为phtml" target="_blank">goutput)

根据文档，这是可能的，但是pg_create_logical_replication_slot只创建一个常规的复制槽。是pgoutput插件造成了所有的魔力吗？如果是，那么就不可能在出版物中使用其他插件，如Wal2json。

我在这里漏掉了什么？

Answer 1

我对Postgres中的逻辑复制和逻辑解码的经验有限，所以如果下面的错误请纠正我。话虽如此，以下是我的发现：

1. 发布支持由pgoutput插件提供。您可以通过特定于插件的选项来使用它。可能是其他插件有可能添加支持，但我不知道逻辑解码插件界面是否暴露了足够的细节。我在wal2json插件版本9e962ba上测试了它，它不能识别这个选项。
2. 复制插槽是独立于发布创建的。在获取更改流时指定要用作筛选器的发布。可以先查看一个发布的更改，然后查看另一个发布的更改，并观察不同的更改集，尽管使用了相同的复制槽（我没有找到它的文档，并且我正在Aurora上测试Postgres兼容性，因此行为可能会有所不同）。
3. 插件输出似乎包括begin和commit的所有条目，即使事务处理没有触及相关发布中包含的任何表。但是，它不包括对发布中包含的其他表的更改。

下面是如何在Postgres 10+中使用它的示例：

-- Create publication
CREATE PUBLICATION cdc;

-- Create slot
SELECT pg_create_logical_replication_slot('test_slot_v1', 'pgoutput');

-- Create example table
CREATE TABLE replication_test_v1
(
  id integer NOT NULL PRIMARY KEY,
  name text
);

-- Add table to publication
ALTER PUBLICATION cdc ADD TABLE replication_test_v1;

-- Insert example data
INSERT INTO replication_test_v1(id, name) VALUES
  (1, 'Number 1')
;

-- Peak changes (does not consume changes)
SELECT pg_logical_slot_peek_binary_changes('test_slot_v1', NULL, NULL, 'publication_names', 'cdc', 'proto_version', '1');

-- Get changes (consumes changes)
SELECT pg_logical_slot_get_binary_changes('test_slot_v1', NULL, NULL, 'publication_names', 'cdc', 'proto_version', '1');