Connexion aux clusters SQL Aurora à l'aide d'un connecteur .NET - Amazon Aurora DSQL

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Connexion aux clusters SQL Aurora à l'aide d'un connecteur .NET

Le connecteur Amazon Aurora DSQL pour .NET est un connecteur .NET basé sur Npgsql qui intègre l'authentification IAM pour connecter les applications .NET aux clusters Amazon Aurora DSQL.

Le connecteur gère la génération de jetons, la configuration SSL et le regroupement des connexions afin que vous puissiez vous concentrer sur la logique de votre application.

À propos du connecteur

Amazon Aurora DSQL nécessite une authentification IAM avec des jetons à durée limitée que les pilotes .NET PostgreSQL existants ne prennent pas en charge de manière native. Le connecteur Aurora DSQL pour .NET ajoute une couche d'authentification au-dessus de Npgsql qui gère la génération de jetons IAM, vous permettant de vous connecter à Aurora DSQL sans modifier vos flux de travail Npgsql existants.

Qu'est-ce que l'authentification SQL Aurora ?

Dans Aurora DSQL, l’authentification implique :

  • Authentification IAM : toutes les connexions utilisent l’authentification basée sur IAM avec des jetons à durée limitée

  • Génération de jetons : le connecteur génère des jetons d'authentification à l'aide AWS d'informations d'identification, et ces jetons ont une durée de vie configurable

Le connecteur Aurora DSQL pour .NET comprend ces exigences et génère automatiquement des jetons d'authentification IAM lors de l'établissement de connexions.

Caractéristiques

  • Authentification IAM automatique : gère la génération et l'actualisation des jetons Aurora DSQL

  • Construit sur Npgsql : intègre le célèbre pilote PostgreSQL pour .NET

  • Intégration fluide - Fonctionne avec les flux de travail Npgsql existants

  • Regroupement de connexions - Support intégré via NpgsqlDataSource avec application de la durée de vie maximale

  • Détection automatique des régions : extrait AWS la région du nom d'hôte du cluster Aurora DSQL

  • AWS support des identifiants - Supporte les AWS profils et les fournisseurs d'identifiants personnalisés

  • Nouvelle tentative OCC - Optez pour une nouvelle tentative de contrôle de simultanéité optimiste avec un recul exponentiel

  • Application du protocole SSL : utilise toujours le protocole SSL avec verify-full mode et négociation directe du protocole TLS

Exemple d'application

Pour un exemple complet, consultez l'exemple d'application sur GitHub.

Guide de démarrage rapide

Exigences

  • .NET 8.0 ou version ultérieure

  • Accès à un cluster SQL Aurora

  • AWS informations d'identification configurées (via la AWS CLI, les variables d'environnement ou les rôles IAM)

Installation

Ajoutez le package à votre projet :

dotnet add package Amazon.AuroraDsql.Npgsql

Usage

Connexion à la piscine

using Amazon.AuroraDsql.Npgsql; // Create a connection pool await using var ds = await AuroraDsql.CreateDataSourceAsync(new DsqlConfig { Host = "your-cluster.dsql.us-east-1.on.aws", OccMaxRetries = 3 }); // Read await using (var conn = await ds.OpenConnectionAsync()) { await using var cmd = conn.CreateCommand(); cmd.CommandText = "SELECT 'Hello, DSQL!'"; var greeting = await cmd.ExecuteScalarAsync(); Console.WriteLine(greeting); } // Transactional write with OCC retry await ds.WithTransactionRetryAsync(async conn => { await using var cmd = conn.CreateCommand(); cmd.CommandText = "INSERT INTO users (id, name) VALUES (gen_random_uuid(), @name)"; cmd.Parameters.AddWithValue("name", "Alice"); await cmd.ExecuteNonQueryAsync(); });

Connexion simple

Pour les scripts simples ou lorsque vous n'avez pas besoin d'un regroupement de connexions :

await using var conn = await AuroraDsql.ConnectAsync(new DsqlConfig { Host = "your-cluster.dsql.us-east-1.on.aws" }); await using var cmd = conn.CreateCommand("SELECT 1"); await cmd.ExecuteScalarAsync();

Réessayer OCC

Aurora DSQL utilise un contrôle de simultanéité optimiste (OCC). Lorsque deux transactions modifient les mêmes données, la première à valider gagne et la seconde reçoit une erreur OCC.

Une nouvelle tentative d'OCC est facultative. Définissez OccMaxRetries la configuration pour activer la nouvelle tentative automatique avec un recul et une instabilité exponentiels. Utilisation WithTransactionRetryAsync pour les écritures transactionnelles :

await ds.WithTransactionRetryAsync(async conn => { await using var cmd = conn.CreateCommand(); cmd.CommandText = "UPDATE accounts SET balance = balance - 100 WHERE id = @from"; cmd.Parameters.AddWithValue("from", fromId); await cmd.ExecuteNonQueryAsync(); cmd.CommandText = "UPDATE accounts SET balance = balance + 100 WHERE id = @to"; cmd.Parameters.Clear(); cmd.Parameters.AddWithValue("to", toId); await cmd.ExecuteNonQueryAsync(); });

Pour les instructions DDL ou uniques, utilisez ExecWithRetryAsync :

await ds.ExecWithRetryAsync("CREATE TABLE IF NOT EXISTS users (id UUID PRIMARY KEY, name TEXT)");
Important

WithTransactionRetryAsyncgèreBEGIN/COMMIT/ROLLBACKen interne et ouvre une nouvelle connexion à chaque tentative. Votre rappel ne doit contenir que des opérations de base de données et vous pouvez réessayer en toute sécurité.

Options de configuration

Le connecteur accepte postgres:// et postgresql:// connecte également des chaînes avec region des paramètres de profile requête.

Champ Type Par défaut Description
Host string (obligatoire) Point de terminaison du cluster ou ID de cluster à 26 caractères
Region string? (détecté automatiquement) AWS région ; obligatoire s'il s'Hostagit d'un ID de cluster
User string "admin" Utilisateur de la base de donnée
Database string "postgres" Nom de la base de données
Port int 5432 Port de la base de données
Profile string? null AWS nom de profil pour les informations d'identification
CustomCredentialsProvider AWSCredentials? null Fournisseur AWS d'identifiants personnalisés
TokenDurationSecs int? null(SDK par défaut, 900s) Durée de validité du jeton en secondes
OccMaxRetries int? null(handicapé) Nombre maximal de tentatives OCC par défaut pour les méthodes de nouvelle tentative sur la source de données
OrmPrefix string? null préfixe ORM préfixé à application_name
LoggerFactory ILoggerFactory? null Logger Factory pour les nouvelles tentatives, les avertissements et les diagnostics
ConfigureConnectionString Action<NpgsqlConnectionStringBuilder>? null Rappel pour annuler les paramètres du pool ou définir des propriétés de chaîne de connexion Npgsql supplémentaires. Les protocoles SSL Enlist sont des invariants de sécurité et ne peuvent pas être remplacés.

Authentification

Le connecteur gère automatiquement l'authentification Aurora DSQL en générant des jetons à l'aide d' AWS informations d'identification. Si vous ne fournissez pas la AWS région, le connecteur l'analyse à partir du nom d'hôte.

Pour plus d'informations sur l'authentification dans Aurora DSQL, consultezAuthentification et autorisation pour Aurora DSQL.

Administrateur et utilisateurs réguliers

  • Les utilisateurs nommés « admin » utilisent automatiquement des jetons d'authentification d'administrateur

  • Tous les autres utilisateurs utilisent des jetons d'authentification ordinaires

  • Le connecteur génère des jetons de manière dynamique pour chaque connexion.