Управление слотами репликации

Кластер Managed Service for PostgreSQL может содержать физические и логические слоты репликации:

• Физические слоты создаются сервисом автоматически на базе хостов-реплик и используются для репликации данных в рамках самого кластера Managed Service for PostgreSQL.
• Логические слоты создаются пользователем и используются для логической репликации данных между кластерами, например при захвате изменений данных (CDC).

Подробности см. в документации PostgreSQL.

Посмотреть список логических слотов репликации

1. Подключитесь к базе данных с помощью учетной записи пользователя с ролью mdb_replication.

2. Выполните SQL-запрос:

   SELECT * FROM pg_replication_slots WHERE slot_type='logical';
   

   Запрос возвращает таблицу всех логических слотов репликации с их параметрами.

Создать слот репликации

1. Задайте максимальный размер WAL при репликации в настройке Max slot wal keep size. Редактирование данной настройки доступно начиная с 13 версии PostgreSQL.

   Важно

   При значении настройки -1 (размер не ограничен) открытые логические слоты репликации, из которых не считывается информация, будут препятствовать удалению WAL-файлов. В результате WAL-файлы займут все дисковое пространство и вы потеряете возможность подключаться к кластеру.

2. Подключитесь к базе данных с помощью учетной записи пользователя с ролью mdb_replication.

3. Выполните SQL-запрос:

   SELECT pg_create_logical_replication_slot 
   ( '<имя слота>', '<имя плагина>', <temporary: true или false>, <two_phase: true или false> )
   

   Где:

   • <имя слота> — уникальное имя слота. Обязательный параметр.
   • <имя плагина> — имя плагина из списка поддерживаемых выходных плагинов. Список см. в разделе Логическое декодирование. Обязательный параметр.
   • temporary — если выбрано значение true, слот будет удален по окончании текущей сессии или при возникновении ошибки. По умолчанию false.
   • two_phase — если выбрано значение true, слот будет декодировать подготовленные транзакции. По умолчанию false.

Удалить слот репликации

1. Подключитесь к базе данных с помощью учетной записи пользователя с ролью mdb_replication.

2. Выполните SQL-запрос:

   SELECT pg_drop_replication_slot ('<имя слота>');
   

Пример

Чтобы создать новый слот репликации с именем json_slot, который декодирует информацию об изменениях базы данных в формат JSON с помощью плагина wal2json:

1. Убедитесь, что в настройке Max slot wal keep size задано значение, отличное от -1.

2. Выполните SQL-запрос:

   SELECT pg_create_logical_replication_slot ( 'json_slot', 'wal2json', false, false );
   

   Вариант ответа:

   pg_create_logical_replication_slot 
   ------------------------------------
   (json_slot,1/92001108)
   (1 row)
   

3. Убедитесь, что слот появился в списке:

   SELECT * from pg_replication_slots;
   

Если слот вам больше не нужен, удалите его:

SELECT pg_drop_replication_slot ('json_slot');