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.

Utilisation d'un pilote client Cassandra Go pour accéder à Amazon Keyspaces par programmation

Cette section explique comment vous connecter à Amazon Keyspaces à l'aide d'un pilote client Go Cassandra. Pour fournir aux utilisateurs et aux applications des informations d'identification leur permettant d'accéder par programmation aux ressources Amazon Keyspaces, vous pouvez effectuer l'une des opérations suivantes :

Avant de commencer

Vous devez effectuer la tâche suivante avant de pouvoir commencer.

Amazon Keyspaces nécessite l'utilisation du protocole TLS (Transport Layer Security) pour sécuriser les connexions avec les clients. Pour vous connecter à Amazon Keyspaces via TLS, vous devez télécharger un certificat numérique Amazon et configurer le pilote Go pour qu'il utilise le protocole TLS.

Téléchargez les certificats numériques suivants et enregistrez les fichiers localement ou dans votre répertoire personnel.

Pour télécharger les certificats, vous pouvez utiliser les commandes suivantes.

curl -O https://www.amazontrust.com/repository/AmazonRootCA1.pem
curl -O https://www.amazontrust.com/repository/AmazonRootCA2.pem
curl -O https://www.amazontrust.com/repository/AmazonRootCA3.pem
curl -O https://www.amazontrust.com/repository/AmazonRootCA4.pem
curl -O https://certs.secureserver.net/repository/sf-class2-root.crt

Combinez tous les certificats téléchargés dans un seul pem fichier avec le nom keyspaces-bundle.pem indiqué dans nos exemples. Pour ce faire, exécutez la commande suivante : Prenez note du chemin d'accès au fichier, vous en aurez besoin plus tard.

cat AmazonRootCA1.pem \
 AmazonRootCA2.pem \
 AmazonRootCA3.pem \
 AmazonRootCA4.pem \
 sf-class2-root.crt \
 > keyspaces-bundle.pem

Connectez-vous à Amazon Keyspaces à l'aide du pilote Gocql pour Apache Cassandra et des informations d'identification spécifiques au service

Connectez-vous à Amazon Keyspaces à l'aide du pilote Go pour Apache Cassandra et du plug-in d'authentification SIGv4

L'exemple de code suivant montre comment utiliser le plug-in d'authentification Sigv4 pour le pilote Go open source afin d'accéder à Amazon Keyspaces (pour Apache Cassandra).

Si ce n'est pas déjà fait, créez des informations d'identification pour votre principal IAM en suivant les étapes décrites àCréation et configuration des AWS informations d'identification pour Amazon Keyspaces. Si une application s'exécute sur Lambda ou sur une instance Amazon EC2, votre application utilise automatiquement les informations d'identification de l'instance. Pour exécuter ce didacticiel localement, vous pouvez stocker les informations d'identification sous forme de variables d'environnement locales.

Ajoutez le plug-in d'authentification Go SigV4 à votre application depuis le GitHub référentiel. Le plugin prend en charge la version 1.2.x du pilote Go open source pour Cassandra et dépend du AWS SDK pour Go.

$ go mod init
$ go get github.com/aws/aws-sigv4-auth-cassandra-gocql-driver-plugin

Dans cet exemple de code, le point de terminaison Amazon Keyspaces est représenté par la Cluster classe. Il utilise la propriété AwsAuthenticator for the authenticator du cluster pour obtenir des informations d'identification.

package main

import (
        "fmt"
        "github.com/aws/aws-sigv4-auth-cassandra-gocql-driver-plugin/sigv4"
        "github.com/gocql/gocql"
        "log"
)

func main() {
    // configuring the cluster options
    cluster := gocql.NewCluster("cassandra.us-west-2.amazonaws.com")
    cluster.Port=9142
    
    // the authenticator uses the default credential chain to find AWS credentials
    cluster.Authenticator = sigv4.NewAwsAuthenticator()

    cluster.SslOpts = &gocql.SslOptions{

            CaPath: "path_to_file/keyspaces-bundle.pem",
            EnableHostVerification: false,
    }
    cluster.Consistency = gocql.LocalQuorum
    cluster.DisableInitialHostLookup = false
   
    session, err := cluster.CreateSession()
    if err != nil {
	    fmt.Println("err>", err)
	    return
    }
    defer session.Close()

    // doing the query
    var text string
    iter := session.Query("SELECT keyspace_name FROM system_schema.tables;").Iter()
    for iter.Scan(&text) {
	    fmt.Println("keyspace_name:", text)
    }
    if err := iter.Close(); err != nil {
	    log.Fatal(err)
    }
}

Remarques d'utilisation :