Métricas para monitorar a replicação mestre-escravo

No lado primário , você deve usar a visualização pg_stat_replicatione comparar diferentes campos para ver o desvio. A função pg_xlog_location_difffornece o tamanho do desvio:

select   pid, client_addr, state, sync_state,  
         pg_xlog_location_diff(sent_location, write_location) as write_lag,  
         pg_xlog_location_diff(sent_location, flush_location) as flush_lag,  
         pg_xlog_location_diff(sent_location, replay_location) as replay_lag
from pg_stat_replication ;

Você pode usar o atraso nas ferramentas de monitoramento, como medidor, para monitorar sua replicação.

Se faltar um standby , você deve verificar no log do standby o porquê.

Se você usar slots de replicação, deverá verificar a pg_replication_slotsexibição.

Um dos métodos que uso (no 9.3) quando estou nos servidores de réplica é ter uma pequena função Bash no .bash_profile que pode ser invocada para mostrar o atraso da réplica. Isso funciona tanto para replicação de streaming quanto para servidores somente após a reprodução do arquivo WAL.

rep()
{
    MASTER='IP or FQDN of master'
    MASTER_CURRENT_XLOG=$(timeout 5 psql -d postgres -U readonlyuser -h "$MASTER" -qtAXc "select pg_current_xlog_location()")
    if [ -n "$MASTER_CURRENT_XLOG" ]; then
        REPLICA_MB_SQL="SELECT ROUND(pg_xlog_location_diff ( '$MASTER_CURRENT_XLOG',  pg_last_xlog_replay_location() ) / 1000000::NUMERIC,3)"
        REPLICA_MINS_SQL="SELECT(CASE WHEN '$MASTER_CURRENT_XLOG' = pg_last_xlog_replay_location() THEN 0 ELSE ROUND((EXTRACT (EPOCH FROM now() - pg_last_xact_replay_timestamp())::NUMERIC)/60,2) END) as replication_lag_seconds"

        # Determine replica delay
        DELAY_IN_MB_FROM_MASTER=$(psql -d postgres -U postgres -qtAXc "$REPLICA_MB_SQL")
        DELAY_IN_MINUTES_FROM_MASTER=$(psql -d postgres -U postgres -qtAXc "$REPLICA_MINS_SQL")

        # Emit replica delay
        echo "Replication delay from master: ${DELAY_IN_MB_FROM_MASTER} MB, ${DELAY_IN_MINUTES_FROM_MASTER} minutes"
    fi
}

Essa função pode ser invocada na linha de comando da réplica com um repcomando simples. Este snippet pressupõe que você tenha um usuário no banco de dados mestre chamado "readonlyuser" (no meu caso, é literalmente um usuário com privs somente leitura) e que a conectividade entre os servidores pela porta 5432 está funcionando. Este é apenas um subconjunto dos detalhes que meu rep()comando emite, tenho algumas outras consultas que me mostram detalhes de integridade do mestre, mas são específicas dos meus dados.

Para versões >= PostgreSQL 10:

select   pid, client_addr, state, sync_state,  
         pg_wal_lsn_diff(sent_lsn, write_lsn) as write_lag,  
         pg_wal_lsn_diff(sent_lsn, flush_lsn) as flush_lag,  
         pg_wal_lsn_diff(sent_lsn, replay_lsn) as replay_lag
from pg_stat_replication;