问题描述
我正在尝试编写一项服务,当多个表发生更改时,该服务将从Postgres DB接收更新。我正在使用psycopg2库在Python中编写它。 我已经找到了一个非常简单的解决方案的示例-使用PUBLICATION和SUBSCRIPTION,但是它没有提供选择哪些表应该触发服务通知的选项。是全有还是全无。
有一个PGologic-Postgres的扩展,它提供了定义应该生成更新的表子集的功能,但是看起来它可以用于同步两个数据库,但我还没有找到任何连接方法pGologic节点使用psycopg2接收通知。
我已经执行以下操作:
replication_test=> CREATE EXTENSION pglogical;
然后
select pglogical.create_node(node_name := 'provider',dsn := 'host=** port=5432 dbname=replication_test');
然后
select pglogical.create_replication_set('first',True,False);
现在,我想知道如何连接到该节点以从作为Lambda或EC2实例运行的Python代码接收表first
上的更新。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)