一个订阅是逻辑复制的下游。定义订阅的节点被称为订阅者。一个订阅定义了到另一个数据库的连接以及它想要订阅的一组发布(一个或多个)。
订阅者数据库的行为方式与任何其他 PostgreSQL 实例相同,并且可以通过定义自己的发布来用作其他数据库的发布者。
如果需要,一个订阅者节点可以有多个订阅。可以在单个发布者-订阅者对之间定义多个订阅,在这种情况下,必须注意确保订阅的发布对象不重叠。
每个订阅都将通过一个复制槽接收更改(请参阅第 26.2.6 节)。初始数据同步预先存在的表数据可能需要额外的复制槽,这些复制槽将在数据同步结束时被删除。
逻辑复制订阅可以是同步复制的备用服务器(请参阅第 26.2.8 节)。默认情况下,备用服务器名称是订阅名称。可以在订阅的连接信息中将备用名称指定为 application_name
。
如果当前用户是超级用户,则订阅将由 pg_dump
转储。否则,会写入警告并跳过订阅,因为非超级用户无法从 pg_subscription
目录中读取所有订阅信息。
使用CREATE SUBSCRIPTION
添加订阅,并可以使用ALTER SUBSCRIPTION
命令随时停止/恢复订阅,并使用DROP SUBSCRIPTION
删除订阅。
当删除并重新创建订阅时,同步信息将丢失。这意味着之后必须重新同步数据。
模式定义不会被复制,并且发布的表必须存在于订阅者上。只有普通表才可以作为复制的目标。例如,您不能复制到视图。
使用完全限定的表名在发布者和订阅者之间匹配表。不支持复制到订阅者上具有不同名称的表。
表的列也按名称匹配。订阅者表中列的顺序不需要与发布者中的顺序匹配。只要数据的文本表示可以转换为目标类型,则列的数据类型不需要匹配。例如,您可以从 integer
类型的列复制到 bigint
类型的列。目标表也可以有发布的表未提供的其他列。任何此类列都将使用目标表定义中指定的默认值填充。但是,二进制格式的逻辑复制限制更多。有关详细信息,请参阅binary
CREATE SUBSCRIPTION
选项。
如前所述,每个(活动的)订阅都从远程(发布)端的复制槽接收更改。
额外的表同步槽通常是瞬态的,在内部创建以执行初始表同步,并在不再需要时自动删除。这些表同步槽具有生成的名称:“pg_%u_sync_%u_%llu
”(参数:订阅oid
,表relid
,系统标识符sysid
)
通常,当使用 CREATE SUBSCRIPTION
创建订阅时,会自动创建远程复制槽,当使用 DROP SUBSCRIPTION
删除订阅时,会自动删除远程复制槽。但是,在某些情况下,单独操作订阅和底层复制槽可能有用或必要。以下是一些场景
创建订阅时,复制槽已经存在。在这种情况下,可以使用 create_slot = false
选项创建订阅,以与现有槽相关联。
创建订阅时,无法访问远程主机或远程主机处于不明确的状态。在这种情况下,可以使用 connect = false
选项创建订阅。然后,根本不会联系远程主机。这是 pg_dump 使用的。然后,必须在激活订阅之前手动创建远程复制槽。
删除订阅时,应保留复制槽。当订阅者数据库被移动到不同的主机并将在那里被激活时,这可能很有用。在这种情况下,在尝试删除订阅之前,使用ALTER SUBSCRIPTION
将槽与订阅解除关联。
删除订阅时,无法访问远程主机。在这种情况下,在尝试删除订阅之前,使用ALTER SUBSCRIPTION
将槽与订阅解除关联。如果远程数据库实例不再存在,则无需进一步操作。但是,如果远程数据库实例只是无法访问,则应手动删除复制槽(和任何仍然存在的表同步槽);否则,它们将继续保留 WAL,并可能最终导致磁盘被填满。应仔细调查此类情况。
在发布者上创建一些测试表。
test_pub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a)); CREATE TABLE test_pub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c)); CREATE TABLE test_pub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e)); CREATE TABLE
在订阅者上创建相同的表。
test_sub=# CREATE TABLE t1(a int, b text, PRIMARY KEY(a)); CREATE TABLE test_sub=# CREATE TABLE t2(c int, d text, PRIMARY KEY(c)); CREATE TABLE test_sub=# CREATE TABLE t3(e int, f text, PRIMARY KEY(e)); CREATE TABLE
在发布者端向表中插入数据。
test_pub=# INSERT INTO t1 VALUES (1, 'one'), (2, 'two'), (3, 'three'); INSERT 0 3 test_pub=# INSERT INTO t2 VALUES (1, 'A'), (2, 'B'), (3, 'C'); INSERT 0 3 test_pub=# INSERT INTO t3 VALUES (1, 'i'), (2, 'ii'), (3, 'iii'); INSERT 0 3
为表创建发布。pub2
和 pub3a
发布不允许某些 publish
操作。发布 pub3b
具有行过滤器(请参阅第 29.4 节)。
test_pub=# CREATE PUBLICATION pub1 FOR TABLE t1; CREATE PUBLICATION test_pub=# CREATE PUBLICATION pub2 FOR TABLE t2 WITH (publish = 'truncate'); CREATE PUBLICATION test_pub=# CREATE PUBLICATION pub3a FOR TABLE t3 WITH (publish = 'truncate'); CREATE PUBLICATION test_pub=# CREATE PUBLICATION pub3b FOR TABLE t3 WHERE (e > 5); CREATE PUBLICATION
为发布创建订阅。订阅 sub3
订阅 pub3a
和 pub3b
。默认情况下,所有订阅都将复制初始数据。
test_sub=# CREATE SUBSCRIPTION sub1 test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub1' test_sub-# PUBLICATION pub1; CREATE SUBSCRIPTION test_sub=# CREATE SUBSCRIPTION sub2 test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub2' test_sub-# PUBLICATION pub2; CREATE SUBSCRIPTION test_sub=# CREATE SUBSCRIPTION sub3 test_sub-# CONNECTION 'host=localhost dbname=test_pub application_name=sub3' test_sub-# PUBLICATION pub3a, pub3b; CREATE SUBSCRIPTION
观察到初始表数据被复制,而与发布的 publish
操作无关。
test_sub=# SELECT * FROM t1; a | b ---+------- 1 | one 2 | two 3 | three (3 rows) test_sub=# SELECT * FROM t2; c | d ---+--- 1 | A 2 | B 3 | C (3 rows)
此外,由于初始数据复制忽略了 publish
操作,并且由于发布 pub3a
没有行过滤器,这意味着复制的表 t3
包含所有行,即使它们与发布 pub3b
的行过滤器不匹配。
test_sub=# SELECT * FROM t3; e | f ---+----- 1 | i 2 | ii 3 | iii (3 rows)
在发布者端向表中插入更多数据。
test_pub=# INSERT INTO t1 VALUES (4, 'four'), (5, 'five'), (6, 'six'); INSERT 0 3 test_pub=# INSERT INTO t2 VALUES (4, 'D'), (5, 'E'), (6, 'F'); INSERT 0 3 test_pub=# INSERT INTO t3 VALUES (4, 'iv'), (5, 'v'), (6, 'vi'); INSERT 0 3
现在,发布者端数据看起来像
test_pub=# SELECT * FROM t1; a | b ---+------- 1 | one 2 | two 3 | three 4 | four 5 | five 6 | six (6 rows) test_pub=# SELECT * FROM t2; c | d ---+--- 1 | A 2 | B 3 | C 4 | D 5 | E 6 | F (6 rows) test_pub=# SELECT * FROM t3; e | f ---+----- 1 | i 2 | ii 3 | iii 4 | iv 5 | v 6 | vi (6 rows)
观察到在正常复制期间使用了相应的 publish
操作。这意味着发布 pub2
和 pub3a
将不会复制 INSERT
。此外,发布 pub3b
将只复制与 pub3b
行过滤器匹配的数据。现在,订阅者端数据看起来像
test_sub=# SELECT * FROM t1; a | b ---+------- 1 | one 2 | two 3 | three 4 | four 5 | five 6 | six (6 rows) test_sub=# SELECT * FROM t2; c | d ---+--- 1 | A 2 | B 3 | C (3 rows) test_sub=# SELECT * FROM t3; e | f ---+----- 1 | i 2 | ii 3 | iii 6 | vi (4 rows)
在某些情况下(例如,第 29.2.1 节),如果远程复制槽不是自动创建的,则用户必须在激活订阅之前手动创建它。以下示例显示了创建槽和激活订阅的步骤。这些示例指定了标准的逻辑解码输出插件 (pgoutput
),这是内置逻辑复制所使用的。
首先,创建一个供示例使用的发布。
test_pub=# CREATE PUBLICATION pub1 FOR ALL TABLES; CREATE PUBLICATION
示例 1:订阅声明 connect = false
的情况
创建订阅。
test_sub=# CREATE SUBSCRIPTION sub1 test_sub-# CONNECTION 'host=localhost dbname=test_pub' test_sub-# PUBLICATION pub1 test_sub-# WITH (connect=false); WARNING: subscription was created, but is not connected HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription. CREATE SUBSCRIPTION
在发布者上,手动创建一个槽。因为在 CREATE SUBSCRIPTION
期间未指定名称,因此要创建的槽的名称与订阅名称相同,例如“sub1”。
test_pub=# SELECT * FROM pg_create_logical_replication_slot('sub1', 'pgoutput'); slot_name | lsn -----------+----------- sub1 | 0/19404D0 (1 row)
在订阅者上,完成订阅的激活。此后,pub1
的表将开始复制。
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; ALTER SUBSCRIPTION test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION; ALTER SUBSCRIPTION
示例 2:订阅声明 connect = false
,但同时也指定了 slot_name
选项。
创建订阅。
test_sub=# CREATE SUBSCRIPTION sub1 test_sub-# CONNECTION 'host=localhost dbname=test_pub' test_sub-# PUBLICATION pub1 test_sub-# WITH (connect=false, slot_name='myslot'); WARNING: subscription was created, but is not connected HINT: To initiate replication, you must manually create the replication slot, enable the subscription, and refresh the subscription. CREATE SUBSCRIPTION
在发布者上,使用在 CREATE SUBSCRIPTION
期间指定的相同名称(例如,“myslot”)手动创建一个槽。
test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'); slot_name | lsn -----------+----------- myslot | 0/19059A0 (1 row)
在订阅者上,剩余的订阅激活步骤与之前相同。
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; ALTER SUBSCRIPTION test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION; ALTER SUBSCRIPTION
示例 3:订阅指定 slot_name = NONE
创建订阅。当 slot_name = NONE
时,还需要 enabled = false
和 create_slot = false
。
test_sub=# CREATE SUBSCRIPTION sub1 test_sub-# CONNECTION 'host=localhost dbname=test_pub' test_sub-# PUBLICATION pub1 test_sub-# WITH (slot_name=NONE, enabled=false, create_slot=false); CREATE SUBSCRIPTION
在发布者上,使用任何名称(例如,“myslot”)手动创建一个槽。
test_pub=# SELECT * FROM pg_create_logical_replication_slot('myslot', 'pgoutput'); slot_name | lsn -----------+----------- myslot | 0/1905930 (1 row)
在订阅者上,将订阅与刚刚创建的槽名称关联。
test_sub=# ALTER SUBSCRIPTION sub1 SET (slot_name='myslot'); ALTER SUBSCRIPTION
剩余的订阅激活步骤与之前相同。
test_sub=# ALTER SUBSCRIPTION sub1 ENABLE; ALTER SUBSCRIPTION test_sub=# ALTER SUBSCRIPTION sub1 REFRESH PUBLICATION; ALTER SUBSCRIPTION
如果您在文档中发现任何不正确的内容,与您使用特定功能的体验不符,或者需要进一步澄清,请使用此表单报告文档问题。