Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Utilizzo di pgactive per supportare la replica active-active

L'pgactiveestensione utilizza la replica attiva-attiva per supportare e coordinare le operazioni di scrittura su più database Postgre. RDS SQL Amazon RDS for Postgre SQL supporta l'pgactiveestensione nelle seguenti versioni:

Inizializzazione della funzionalità di estensione pgactive

Per inizializzare la funzionalità di pgactive estensione sulla tua istanza SQL DB RDS for Postgre, imposta il valore del rds.enable_pgactive parametro su, quindi crea l'estensione nel database. 1 In questo modo si attivano automaticamente i parametri rds.logical_replication e track_commit_timestamp e il valore wal_level viene impostato su logical.

Per eseguire queste attività sono richieste le autorizzazioni del ruolo rds_superuser.

Puoi usare AWS Management Console o the AWS CLI per creare le istanze database necessarie RDS per SQL Postgre. I passaggi seguenti presuppongono che l'istanza SQL DB RDS for Postgre sia associata a un gruppo di parametri DB personalizzato. Per ulteriori informazioni sulla creazione di un gruppo di parametri personalizzato, consulta Gruppi di parametri per RDS.

Configurazione della replica attiva-attiva per il cluster RDS SQL

La procedura seguente mostra come avviare la replica attiva-attiva tra due cluster 15.4 o versioni successive nella stessa regione. SQL Per eseguire l'esempio di alta disponibilità multiregionale, devi distribuire SQL istanze Amazon RDS for Postgre in due regioni diverse e configurare Peering. VPC Per ulteriori informazioni, consulta la sezione peering. VPC

Questi passaggi presuppongono che l'istanza SQL DB RDS for Postgre sia stata configurata con l'estensione. pgactive Per ulteriori informazioni, consulta Inizializzazione della funzionalità di estensione pgactive.

Gestione dei conflitti nella replica active-active

L'estensione pgactive funziona per database e non per cluster. Ogni istanza database che utilizza pgactive è un'istanza indipendente e può accettare modifiche ai dati da qualsiasi origine. Quando una modifica viene inviata a un'istanza DB, Postgre la esegue localmente e quindi la utilizza pgactive per replicare SQL la modifica in modo asincrono su altre istanze DB. Quando due istanze SQL DB Postgre aggiornano lo stesso record quasi contemporaneamente, può verificarsi un conflitto.

L'estensione pgactive fornisce meccanismi per il rilevamento dei conflitti e la risoluzione automatica. Tiene traccia del timestamp in cui è stata effettuata la transazione su entrambe le istanze database e applica automaticamente la modifica con il timestamp più recente. L'estensione pgactive registra anche quando si verifica un conflitto nella tabella pgactive.pgactive_conflict_history.

pgactive.pgactive_conflict_historyContinueranno a crescere. Potresti voler definire una politica di eliminazione. Questo può essere fatto cancellando alcuni record regolarmente o definendo uno schema di partizionamento per questa relazione (e successivamente staccando, eliminando e troncando le partizioni di interesse). Per implementare regolarmente la politica di eliminazione, un'opzione è utilizzare l'estensione. pg_cron Vedi le seguenti informazioni su un esempio della tabella di pg_cron cronologia, Pianificazione della manutenzione con l'estensione SQL Postgre pg_cron.

Gestione delle sequenze nella replica active-active

E RDS per Postgre SQL DB, un'istanza con pgactive estensione utilizza due diversi meccanismi di sequenza per generare valori univoci.

Sequenze globali

Per utilizzare una sequenza globale, crea una sequenza locale con l'istruzione CREATE SEQUENCE. Utilizza pgactive.pgactive_snowflake_id_nextval(seqname) invece di usingnextval(seqname) per ottenere il valore univoco successivo della sequenza.

L'esempio seguente crea una sequenza globale:

postgres=> CREATE TABLE gstest (
      id bigint primary key,
      parrot text
    );

postgres=>CREATE SEQUENCE gstest_id_seq OWNED BY gstest.id;

postgres=> ALTER TABLE gstest \
      ALTER COLUMN id SET DEFAULT \
      pgactive.pgactive_snowflake_id_nextval('gstest_id_seq');

Sequenze partizionate

Nelle sequenze suddivise o partizionate, viene utilizzata una normale sequenza Postgre su ciascun nodo. SQL Ogni sequenza incrementa della stessa quantità e inizia con offset diversi. Ad esempio, con il passaggio 100, il nodo 1 genera una sequenza come 101, 201, 301 e così via e il nodo 2 genera una sequenza come 102, 202, 302 e così via. Questo schema funziona bene anche se i nodi non possono comunicare per periodi prolungati, ma richiede che il progettista specifichi un numero massimo di nodi al momento di stabilire lo schema e richiede una configurazione per nodo. Gli errori possono facilmente portare alla sovrapposizione di sequenze.

È relativamente semplice configurare questo approccio con pgactive creando la sequenza desiderata su un nodo nel modo seguente:

CREATE TABLE some_table (generated_value bigint primary key);

postgres=> CREATE SEQUENCE some_seq INCREMENT 100 OWNED BY some_table.generated_value;

postgres=> ALTER TABLE some_table ALTER COLUMN generated_value SET DEFAULT nextval('some_seq');
    

Quindi richiama setval su ogni nodo per assegnare un valore iniziale di offset diverso nel modo seguente.

postgres=>
-- On node 1
SELECT setval('some_seq', 1);

-- On node 2
SELECT setval('some_seq', 2);     

Riferimento ai parametri dell'estensione pgactive

È possibile utilizzare la seguente query per visualizzare tutti i parametri associati all'estensione pgactive.

postgres=> SELECT * FROM pg_settings WHERE name LIKE 'pgactive.%';

Misurazione del ritardo di replica tra i membri pgattivi

È possibile utilizzare la seguente query per visualizzare il ritardo di replica tra i membri. pgactive Esegui questa query su ogni pgactive nodo per ottenere il quadro completo.

      postgres=# SELECT *, (last_applied_xact_at - last_applied_xact_committs) AS lag FROM pgactive.pgactive_node_slots;
-{ RECORD 1 ]----------------+----------------------------------------------------------------- 
node_name                    | node2-app
slot_name                    | pgactive_5_7332551165694385385_0_5__
slot_restart_lsn             | 0/1A898A8
slot_confirmed_lsn           | 0/1A898E0
walsender_active             | t
walsender_pid                | 69022
sent_lsn                     | 0/1A898E0 
write_lsn                    | 0/1A898E0
flush_lsn                    | 0/1A898E0  
replay_lsn                   | 0/1A898E0
last_sent_xact_id            | 746
last_sent_xact_committs      | 2024-02-06 18:04:22.430376+00
last_sent_xact_at            | 2024-02-06 18:04:22.431359+00
last_applied_xact_id         | 746
last_applied_xact_committs   | 2024-02-06 18:04:22.430376+00
last_applied_xact_at         | 2024-02-06 18:04:52.452465+00
lag                          | 00:00:30.022089

Limitazioni per l'estensione pgactive