Backup PostgreSQL a Zero-Downtime su Cloudflare R2 con PGStash

I backup non gestiti del database rappresentano un rischio critico per l'ambiente di produzione. Lanciare un comune pg_dump su un database ad alto traffico blocca spesso le tabelle, provoca picchi di IOPS e rischia di esaurire lo spazio su disco prima di inviare il file allo storage cloud.

L'Architettura: Pipeline, Cifratura e Streaming

PGStash elimina i limiti dello storage locale incanalando lo stdout di pg_dump direttamente attraverso la cifratura OpenSSL AES-256-CBC verso uno storage di oggetti compatibile S3 come Cloudflare R2. Questo approccio azzera i costi di traffico in uscita ed elimina i colli di bottiglia in scrittura su disco.

Streaming e Cifratura in Python verso Cloudflare R2

import os
import subprocess
import boto3
from botocore.config import Config

def stream_backup_to_r2(db_url: str, bucket: str, key: str):
    s3_client = boto3.client(
        's3',
        endpoint_url=os.environ['R2_ENDPOINT_URL'],
        aws_access_key_id=os.environ['R2_ACCESS_KEY_ID'],
        aws_secret_access_key=os.environ['R2_SECRET_ACCESS_KEY'],
        config=Config(signature_version='s3v4')
    )

    # Avvia pg_dump senza scrivere su disco locale
    dump_proc = subprocess.Popen(
        ['pg_dump', f'--dbname={db_url}', '--format=custom', '--no-owner'],
        stdout=subprocess.PIPE
    )

    # Incanala lo stdout del dump direttamente nel processo di cifratura AES-256
    enc_proc = subprocess.Popen(
        ['openssl', 'enc', '-aes-256-cbc', '-pbkdf2', '-pass', f'pass:{os.environ["ENCRYPTION_KEY"]}'],
        stdin=dump_proc.stdout,
        stdout=subprocess.PIPE
    )
    dump_proc.stdout.close()

    # Invia il flusso di byte crittografato a R2
    s3_client.upload_fileobj(enc_proc.stdout, bucket, key)
    enc_proc.wait()
    print(f"[+] Backup inviato e crittografato con successo su R2: {key}")

Schedulazione Cron e Monitoraggio dei Log

L'automazione richiede osservabilità rigorosa. Collega la pipeline di streaming a systemd timer o job cron che emettono log strutturati in JSON per tracciare tempi di esecuzione, dimensione del payload e codici di errore.

Test Automatici di Ripristino

Un backup non verificato non offre alcuna garanzia. Configura test di ripristino automatici con cadenza settimanale all'interno di un container Docker isolato: scarica l'artifact crittografato da R2, decifralo in memoria, ripristinalo su un'istanza PostgreSQL pulita ed esegui i controlli d'integrità dello schema.

L'adozione di questa architettura assicura la conformità nella conservazione dei dati, riduce drasticamente i costi di egress e garantisce RTO (Recovery Time Objective) inferiori al minuto in caso di disaster recovery.