5

我正在使用逻辑复制将数据从 Postgres 10.4 复制到另一个 Postgres 10.4 实例。

订阅者有多个将事件记录到单个表的触发器。此表有一个触发器，它执行另一个函数（返回触发器）来为下游侦听器调用 NOTIFY。

审计表上的触发器如下所示：

CREATE TRIGGER queue_insert
    AFTER INSERT ON schema_name.table_name FOR EACH ROW
     EXECUTE PROCEDURE notify_downstream()
GO

通知下游定义：

CREATE OR REPLACE FUNCTION schema_name.notify_downstream () RETURNS trigger AS
'
declare
message character varying;
begin

raise log ''notify running!'';

message := ''
{ "id": 'edited for brevity' }

'';
execute ''notify chan_name, '''''' || message || '''''''';

raise log ''Value: %'', message;
return new;
end;
'
LANGUAGE 'plpgsql'
GO

使用日志记录，我能够证明这是触发。我还可以看到有数据使用：

select pg_notification_queue_usage()

问题是在我插入表（读作：逻辑复制之外）以使触发器触发之前，没有一个侦听器收到消息，然后侦听器接收到所有应该从逻辑复制发送的通知消息。

在我们转向逻辑复制之前，所有这些都运行良好（我们有一个已退役的本土解决方案，我对此一无所知）。

我没有收到任何可以给我任何线索的错误或奇怪的信息。我也发现了日志的详细程度，除了我添加到函数中以验证它们是否正在运行的日志语句之外，没有看到与通知相关的任何内容。

Stack Overflow 上某人的另一份报告：Notify From Trigger On PG Logical Replicated Table

问题：如何调试此问题？如何让听众接收消息而不手动插入一行让它们突然出现？

4

1 回答 1

2

更新：看起来这是PostgreSQL 10.4 的一个错误，至少至少达到11.4。这里有一个实验性补丁。

根据PostgreSQL 邮件列表上的这篇文章，默认情况下，逻辑复制不会导致触发器在副本上触发，因为表通常具有“本地”复制角色，而在逻辑副本上，数据以“副本”角色插入。

看起来您可以更改表以始终触发触发器，包括通过执行以下操作进行复制（请参阅此处的文档）：

ALTER TABLE my_table ENABLE ALWAYS TRIGGER my_trigger;

于 2018-07-23T15:14:45.643 回答