На узле подписчика используйте следующий SQL, чтобы определить, какие слоты репликации должны быть синхронизированы с резервным узлом, который мы планируем повысить. Этот запрос вернет соответствующие слоты репликации, связанные с подписками, поддерживающими отказоустойчивость.

test_sub=# SELECT
               array_agg(quote_literal(s.subslotname)) AS slots
           FROM  pg_subscription s
           WHERE s.subfailover AND
                 s.subslotname IS NOT NULL;
 slots
-------
 {'sub1','sub2','sub3'}
(1 row)

На узле подписчика используйте следующий SQL, чтобы определить, какие слоты синхронизации таблиц должны быть синхронизированы с резервным сервером, который мы планируем повысить. Этот запрос необходимо выполнить в каждой базе данных, которая включает подписки с поддержкой отказа. Обратите внимание, что слот синхронизации таблицы должен быть синхронизирован с резервным сервером только в том случае, если копирование таблицы завершено (см. Раздел 51.55). Нам не нужно обеспечивать синхронизацию слотов синхронизации таблиц в других сценариях, так как они будут либо удалены, либо воссозданы на новом основном сервере в этих случаях.

test_sub=# SELECT
               array_agg(quote_literal(slot_name)) AS slots
           FROM
           (
               SELECT CONCAT('pg_', srsubid, '_sync_', srrelid, '_', ctl.system_identifier) AS slot_name
               FROM pg_control_system() ctl, pg_subscription_rel r, pg_subscription s
               WHERE r.srsubstate = 'f' AND s.oid = r.srsubid AND s.subfailover
           );
 slots
-------
 {'pg_16394_sync_16385_7394666715149055164'}
(1 row)

Проверьте, что логические слоты репликации, указанные выше, существуют на резервном сервере и готовы к переключению.

test_standby=# SELECT slot_name, (synced AND NOT temporary AND NOT conflicting) AS failover_ready
               FROM pg_replication_slots
               WHERE slot_name IN
                   ('sub1','sub2','sub3', 'pg_16394_sync_16385_7394666715149055164');
  slot_name                                 | failover_ready
--------------------------------------------+----------------
  sub1                                      | t
  sub2                                      | t
  sub3                                      | t
  pg_16394_sync_16385_7394666715149055164   | t
(4 rows)