Блог

Я пытаюсь написать сервис, который будет получать обновления из Postgres DB при изменении нескольких таблиц. Я пишу это на Python, используя библиотеку psycopg2. Я нашел несколько примеров очень простого решения — использование ПУБЛИКАЦИИ и ПОДПИСКИ, но оно не предоставляет возможности выбирать, какие таблицы должны вызывать уведомление службы. Все или ничего.

Существует Pglogical — расширение для Postgres, которое предоставляет возможность определять подмножество таблиц, которые должны генерировать обновление, но, похоже, его можно использовать для синхронизации двух баз данных, я не нашел никакого способа подключиться к узлу pglogical для получения уведомлений с помощью 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, True, True, False);
  

Теперь мне интересно, как я могу подключиться к этому узлу, чтобы получать обновления для таблицы first из кода Python, работающего как экземпляр Lambda или EC2.