监听/通知流失败

问题描述

我正在尝试使用Postgresql中的通道来传达python脚本所插入的值。主要目标是将数据从postgresql流传输到python脚本。我已经知道NOTIFY和LISTEN是执行此操作的好方法，但是我对其他也可以解决问题的解决方案持开放态度。

我创建了一个触发器，如下所示：

create or replace function notifications() returns trigger as $$

declare ts timestamp without time zone := (select NEW.date);
        b double precision := (select NEW.b);
        a double precision := (select NEW.a);
        msg varchar := null;
begin
    msg := 'timestamp %,b %,a %',ts,b,a;
    select pg_notify('virtual_channel',msg);
    RETURN null;
end;
$$ language plpgsql;

create trigger notifier 
after insert on test_table
for each row execute notifications();

这在编译时不会出错，但是会使表停止接收新数据的新条目，并且也不会发送所需的通知。 为什么这失败了？使用"NOTIFY channel,message"选项更好吗？我尝试先使用它，但是由于创建msg消息的方式而无法使用它。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）