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 un driver client Cassandra Go per accedere ad Amazon Keyspaces a livello di codice
Questa sezione mostra come connettersi ad Amazon Keyspaces utilizzando un driver client Go. Per fornire agli utenti e alle applicazioni le credenziali per l'accesso programmatico alle risorse di Amazon Keyspaces, puoi effettuare una delle seguenti operazioni:
-
Crea credenziali specifiche del servizio associate a un utente specifico (IAM). AWS Identity and Access Management
-
Per una maggiore sicurezza, consigliamo di creare chiavi di accesso IAM per utenti e ruoli IAM che vengono utilizzati in tutti i servizi. AWS Il plug-in di autenticazione Amazon Keyspaces SigV4 per i driver client Cassandra consente di autenticare le chiamate ad Amazon Keyspaces utilizzando chiavi di accesso IAM anziché nome utente e password. Per ulteriori informazioni, consulta Come creare e configurare AWS credenziali per Amazon Keyspaces.
Argomenti
Prima di iniziare
È necessario completare la seguente attività prima di iniziare.
Amazon Keyspaces richiede l'uso di Transport Layer Security (TLS) per proteggere le connessioni con i client. Per connetterti ad Amazon Keyspaces tramite TLS, devi scaricare un certificato digitale Amazon e configurare il driver Python per utilizzare TLS.
Scarica il certificato digitale Starfield utilizzando il seguente comando e salvalo sf-class2-root.crt
localmente o nella tua home directory.
curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
Nota
Puoi anche utilizzare il certificato digitale Amazon per connetterti ad Amazon Keyspaces e puoi continuare a farlo se il tuo client si connette ad Amazon Keyspaces con successo. Il certificato Starfield offre un'ulteriore compatibilità con le versioni precedenti per i client che utilizzano autorità di certificazione precedenti.
curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
Connect ad Amazon Keyspaces utilizzando il driver Gocql per Apache Cassandra e le credenziali specifiche del servizio
-
Crea una directory per l'applicazione.
mkdir ./gocqlexample
-
Accedere alla nuova directory.
cd gocqlexample
-
Crea un file per la tua applicazione.
touch cqlapp.go
-
Scarica il driver Go.
go get github.com/gocql/gocql
-
Aggiungi il seguente codice di esempio al file cqlapp.go.
package main import ( "fmt" "github.com/gocql/gocql" "log" ) func main() { // add the Amazon Keyspaces service endpoint cluster := gocql.NewCluster("
cassandra.us-east-2.amazonaws.com
") cluster.Port=9142 // add your service specific credentials cluster.Authenticator = gocql.PasswordAuthenticator{ Username: "ServiceUserName
", Password: "ServicePassword
"} // provide the path to the sf-class2-root.crt cluster.SslOpts = &gocql.SslOptions{ CaPath: "path_to_file
/sf-class2-root.crt", EnableHostVerification: false, } // Override default Consistency to LocalQuorum cluster.Consistency = gocql.LocalQuorum cluster.DisableInitialHostLookup = false session, err := cluster.CreateSession() if err != nil { fmt.Println("err>", err) } defer session.Close() // run a sample query from the system keyspace 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) } session.Close() }Note sull'utilizzo:
Sostituisci
"
con il percorso del certificato salvato nel primo passaggio.path_to_file
/sf-class2-root.crt"Assicurati che il
ServiceUsernome
e la passwordServicePassword
corrispondano al nome utente e alla password che hai ottenuto quando hai generato le credenziali specifiche del servizio seguendo i passaggi da. Genera credenziali specifiche per il servizioPer un elenco degli endpoint disponibili, consulta. Endpoint di servizio per Amazon Keyspaces
Crea il programma.
go build cqlapp.go
Esegui il programma.
./cqlapp
Connect ad Amazon Keyspaces utilizzando il driver Go per Apache Cassandra e il plug-in di autenticazione SigV4
Il seguente esempio di codice mostra come utilizzare il plug-in di autenticazione SigV4 per il driver open source Go per accedere ad Amazon Keyspaces (per Apache Cassandra).
Se non l'hai già fatto, crea le credenziali per il tuo utente o ruolo IAM seguendo la procedura riportata qui. Come creare e configurare AWS credenziali per Amazon Keyspaces
Aggiungi il plug-in di autenticazione Go SigV4 all'applicazione dal repository. GitHub
$ go mod init $ go get github.com/aws/aws-sigv4-auth-cassandra-gocql-driver-plugin
In questo esempio di codice, l'endpoint Amazon Keyspaces è rappresentato dalla classe. Cluster
Utilizza la proprietà AwsAuthenticator
for the authenticator del cluster per ottenere le credenziali.
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 var auth sigv4.AwsAuthenticator = sigv4.NewAwsAuthenticator() auth.Region = "us-west-2
" auth.AccessKeyId = "AKIAIOSFODNN7EXAMPLE
" auth.SecretAccessKey = "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY
" cluster.Authenticator = auth cluster.SslOpts = &gocql.SslOptions{ CaPath: "path_to_file
/sf-class2-root.crt", 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) } }
Note sull'utilizzo:
Sostituisci
"
con il percorso del certificato salvato nel primo passaggio.path_to_file
/sf-class2-root.crt"Assicurati che l'
AccessKeyID
e laSecretAccesschiave
corrispondano alla chiave di accesso e alla chiave di accesso segreta che hai ottenuto utilizzandoAwsAuthenticator
. Per ulteriori informazioni, consulta Configurazione dell' AWS SDK for Go in. AWS SDK for GoPer archiviare le chiavi di accesso al di fuori del codice, consulta le best practice all'indirizzo. Come gestire le chiavi di accesso per gli utenti IAM
Per un elenco degli endpoint disponibili, consultaEndpoint di servizio per Amazon Keyspaces.