Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Uso de un controlador de cliente Go para Cassandra para acceder a Amazon Keyspaces mediante programación
En esta sección le mostramos cómo conectarse a Amazon Keyspaces mediante un controlador de cliente Go. Para proporcionar a los usuarios y a las aplicaciones credenciales de acceso programático a los recursos de Amazon Keyspaces, puede realizar cualquiera de las siguientes acciones:
-
Cree credenciales específicas del servicio que se vinculen a un usuario de AWS Identity and Access Management (IAM) específico.
-
Para mejorar la seguridad, recomendamos crear claves de acceso de IAM para los usuarios y roles de IAM que se utilicen en todos los servicios. AWS El complemento de autenticación SigV4 de Amazon Keyspaces para controladores de cliente de Cassandra habilita la autenticación de llamadas a Amazon Keyspaces utilizando claves de acceso de IAM en vez de nombre de usuario y contraseña. Para obtener más información, consulte Cómo crear y configurar AWS credenciales para Amazon Keyspaces.
Temas
Antes de empezar
Debe completar la siguiente tarea antes de comenzar.
Amazon Keyspaces requiere el uso de Seguridad de la capa de transporte (TLS) para ayudar a proteger las conexiones con los clientes. Para conectarse a Amazon Keyspaces mediante TLS, necesita descargar un certificado digital de Amazon y configurar el controlador Python para utilizar TLS.
Descargue el certificado digital de Starfield utilizando el siguiente comando y guarde sf-class2-root.crt
localmente o en su directorio de inicio.
curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
nota
También puede utilizar el certificado digital de Amazon para conectarse a Amazon Keyspaces, y puede seguir haciéndolo si su cliente se conecta a Amazon Keyspaces correctamente. El certificado de Starfield proporciona compatibilidad retroactiva adicional para los clientes que utilicen autoridades de certificación más antiguas.
curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
Conexión a Amazon Keyspaces mediante el controlador Gocql para Apache Cassandra y credenciales específicas del servicio
-
Cree un directorio para la aplicación.
mkdir ./gocqlexample
-
Vaya al nuevo directorio.
cd gocqlexample
-
Cree un archivo para su aplicación.
touch cqlapp.go
-
Descargue el controlador Go.
go get github.com/gocql/gocql
-
Añada el siguiente código de ejemplo al nuevo archivo.
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() }Notas de uso:
Sustituya
"
por la ruta al certificado guardado en el primer paso.path_to_file
/sf-class2-root.crt"Asegúrese de que el
ServiceUsernombre
coincide con el nombre de usuario y la contraseña que obtuvo al generar las credenciales específicas del servicio siguiendo los pasos que se indican a continuación. Generación de credenciales específicas del servicioServicePassword
Para obtener una lista de los puntos de conexión disponibles, consulte Puntos de conexión de servicio para Amazon Keyspaces.
Compile el programa.
go build cqlapp.go
Ejecute el programa.
./cqlapp
Conexión a Amazon Keyspaces mediante el controlador Go para Apache Cassandra y el complemento de autenticación SigV4
El siguiente ejemplo de código muestra cómo utilizar el complemento de autenticación SigV4 para el controlador Go de código abierto para acceder a Amazon Keyspaces (para Apache Cassandra).
Si aún no lo ha hecho, cree credenciales para su usuario o rol de IAM; para ello, siga los pasos que se indican en Cómo crear y configurar AWS credenciales para Amazon Keyspaces.
Añada el complemento de autenticación Go SiGv4 a su aplicación desde el repositorio. GitHub
$ go mod init $ go get github.com/aws/aws-sigv4-auth-cassandra-gocql-driver-plugin
En este ejemplo de código, el punto de conexión de Amazon Keyspaces está representado por la clase Cluster
. Utiliza el AwsAuthenticator
de la propiedad de autenticador del clúster para obtener las credenciales.
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) } }
Notas de uso:
Sustituya
"
por la ruta al certificado guardado en el primer paso.path_to_file
/sf-class2-root.crt"Asegúrate de que el
AccessKeyidentificador
y laSecretAccessclave coincidan con la clave
de acceso y la clave de acceso secreta que obtuviste con ella.AwsAuthenticator
Para obtener más información, consulte Configuración del SDK de AWS para Go en la AWS SDK for Go.Para almacenar las claves de acceso fuera del código, consulta las prácticas recomendadas en Administración de claves de acceso para usuarios de IAM.
Para obtener una lista de los puntos de conexión disponibles, consulte Puntos de conexión de servicio para Amazon Keyspaces.