• Необходимость переноса или агрегации отдельных таблиц в аналитическое DWH-хранилище.
• Миграция базы данных на новую мажорную версию PostgreSQL с околонулевым Downtime.
• Ошибки репликации из-за отсутствия первичных ключей REPLICA IDENTITY на целевых таблицах.

1. Настройка источника (Publisher) в postgresql.conf

wal_level = logical
max_replication_slots = 10
max_wal_senders = 10

Перезапустите СУБД и создайте публикацию таблиц:

-- Публикация конкретных таблиц
CREATE PUBLICATION pub_sales FOR TABLE orders, order_items;

-- Либо публикация всех таблиц базы данных
-- CREATE PUBLICATION pub_all_tables FOR ALL TABLES;

2. Подготовка схемы на приемнике (Subscriber)

Логическая репликация не реплицирует DDL. Создайте структуру таблиц на сервере-приемнике вручную:

CREATE TABLE orders (id BIGINT PRIMARY KEY, customer_id INT, amount NUMERIC(10,2), created_at TIMESTAMPTZ);
CREATE TABLE order_items (id BIGINT PRIMARY KEY, order_id BIGINT, product_id INT, quantity INT);

3. Создание подписки на сервере-приемнике

CREATE SUBSCRIPTION sub_sales 
CONNECTION 'host=192.168.10.50 port=5432 dbname=production user=replicator password=Secret'
PUBLICATION pub_sales
WITH (copy_data = true, create_slot = true);

4. Проверка и траблшутинг состояния подписки

На стороне подписчика проверьте статус воркеров:

SELECT subname, pid, received_lsn, last_msg_send_time, latest_end_time 
FROM pg_stat_subscription;

На стороне источника проверьте состояние слота логической репликации:

SELECT slot_name, plugin, active, confirmed_flush_lsn 
FROM pg_replication_slots 
WHERE slot_type = 'logical';