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à.

Connessione ai cluster Aurora DSQL con un connettore Ruby

L'Aurora DSQL Connector for Ruby è un connettore Ruby basato su pg che integra l'autenticazione IAM per connettere le applicazioni Ruby ai cluster DSQL di Amazon Aurora.

Il connettore gestisce la generazione di token, la configurazione SSL e il pool di connessioni in modo che tu possa concentrarti sulla logica dell'applicazione.

Informazioni sul connettore

Amazon Aurora DSQL richiede l'autenticazione IAM con token a tempo limitato che i driver Ruby PostgreSQL esistenti non supportano nativamente. L'Aurora DSQL Connector per Ruby aggiunge un livello di autenticazione alla gemma pg che gestisce la generazione di token IAM, consentendoti di connetterti ad Aurora DSQL senza modificare i flussi di lavoro pg esistenti.

Cos'è l'autenticazione Aurora DSQL?

In Aurora DSQL, l’autenticazione prevede:

L'Aurora DSQL Connector per Ruby comprende questi requisiti e genera automaticamente token di autenticazione IAM quando stabilisce le connessioni.

Funzionalità

Esempio di applicazione

Per un esempio completo, vedi l'applicazione di esempio su GitHub.

Guida rapida di avvio

Requisiti

Installazione

Aggiungi al tuo Gemfile:

gem "aurora-dsql-ruby-pg"

Oppure installa direttamente:

gem install aurora-dsql-ruby-pg

Utilizzo

Connessione alla piscina

require "aurora_dsql_pg"

# Create a connection pool with OCC retry enabled
pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster.dsql.us-east-1.on.aws",
  occ_max_retries: 3
)

# Read
pool.with do |conn|
  result = conn.exec("SELECT 'Hello, DSQL!'")
  puts result[0]["?column?"]
end

# Write — you must wrap writes in a transaction
pool.with do |conn|
  conn.transaction do
    conn.exec_params("INSERT INTO users (id, name) VALUES (gen_random_uuid(), $1)", ["Alice"])
  end
end

pool.shutdown

Connessione singola

Per script semplici o quando non è necessario il pool di connessioni:

conn = AuroraDsql::Pg.connect(host: "your-cluster.dsql.us-east-1.on.aws")
conn.exec("SELECT 1")
conn.close

Utilizzo avanzato

Configurazione dell'host

Il connettore supporta sia gli endpoint completi del cluster (regione rilevata automaticamente) che il cluster IDs (regione richiesta):

# Full endpoint (region auto-detected)
pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster.dsql.us-east-1.on.aws"
)

# Cluster ID (region required)
pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster-id",
  region: "us-east-1"
)

AWS profili

Specificare un AWS profilo per le credenziali:

pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster.dsql.us-east-1.on.aws",
  profile: "production"
)

Formato della stringa di connessione

Il connettore supporta i formati di stringhe di connessione PostgreSQL:

postgres://[user@]host[:port]/[database][?param=value&...]
postgresql://[user@]host[:port]/[database][?param=value&...]

Parametri di interrogazione supportati:region,,. profile tokenDurationSecs

# Full endpoint with profile
pool = AuroraDsql::Pg.create_pool(
  "postgres://admin@cluster.dsql.us-east-1.on.aws/postgres?profile=dev"
)

Riprova OCC

Aurora DSQL utilizza il controllo ottimistico della concorrenza (OCC). Quando due transazioni modificano gli stessi dati, la prima che esegue il commit vince e la seconda riceve un errore OCC.

Il nuovo tentativo OCC è facoltativo. Imposta al occ_max_retries momento della creazione del pool per abilitare i nuovi tentativi automatici con backoff e jitter esponenziali attivi: pool.with

pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster.dsql.us-east-1.on.aws",
  occ_max_retries: 3
)

pool.with do |conn|
  conn.transaction do
    conn.exec_params("UPDATE accounts SET balance = balance - $1 WHERE id = $2", [100, from_id])
    conn.exec_params("UPDATE accounts SET balance = balance + $1 WHERE id = $2", [100, to_id])
  end
end

Per evitare di ripetere le singole chiamate, inserisci: retry_occ: false

pool.with(retry_occ: false) do |conn|
  conn.exec("SELECT 1")
end

Opzioni di configurazione

create_poolaccetta anche una pool: parola chiave con un hash di opzioni a cui passi direttamente. ConnectionPool.new Se si omettepool:, per impostazione predefinita il connettore è. {size: 5, timeout: 5} Le chiavi fornite sostituiscono solo quelle impostazioni predefinite specifiche.

pool = AuroraDsql::Pg.create_pool(
  host: "your-cluster.dsql.us-east-1.on.aws",
  pool: { size: 10, timeout: 10 }
)

Autenticazione

Il connettore gestisce automaticamente l'autenticazione Aurora DSQL generando token utilizzando credenziali. AWS Se non fornite la AWS regione, il connettore la analizza a partire dal nome host.

Per ulteriori informazioni sull'autenticazione in Aurora DSQL, vedere. Autenticazione e autorizzazione per Aurora DSQL

Amministratore e utenti normali