使用 Cassandra Python 客户端驱动程序以编程方式访问亚马逊Keyspaces - Amazon Keyspaces (for Apache Cassandra)
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Cassandra Python 客户端驱动程序以编程方式访问亚马逊Keyspaces

在本节中,我们将向您介绍如何使用 Python 客户端驱动程序连接到 Amazon Keyspaces。要向用户和应用程序提供凭证以编程方式访问 Amazon Keyspaces 资源,您可以执行以下任一操作:

  • 创建与特定Amazon Identity and Access Management (IAM) 用户关联的服务特定凭证。

  • 为了增强安全性,我们建议为所有Amazon服务中使用的 IAM 用户或角色创建 IAM 访问密钥。适用于 Cassandra 客户端驱动程序的 Amazon Keyspaces Sigv4 身份验证插件使您能够使用 IAM 访问密钥而不是用户名和密码对对 Amazon Keyspaces 的调用进行身份验证。有关更多信息,请参阅如何创建和配置AmazonAmazon Keyspaces 凭证

开始前的准备工作

您需要完成以下任务才能开始。

Amazon Keyspaces 要求使用传输层安全 (TLS) 来帮助保护与客户端的连接。要使用 TLS 连接到亚马逊Keyspaces,您需要下载亚马逊数字证书并将 Python 驱动程序配置为使用 TLS。

使用以下命令下载 Starfield 数字证书并保存在sf-class2-root.crt本地或主目录中。

curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
注意

您还可以使用亚马逊数字证书连接到 Amazon Keyspaces,如果您的客户成功连接到 Amazon Keyspaces,则可以继续这样做。Starfield 证书为使用旧证书颁发机构的客户端提供了额外的向后兼容性。

curl https://certs.secureserver.net/repository/sf-class2-root.crt -O

使用适用于 Apache Cassandra 的 Python 驱动程序和特定于服务的凭证Connect 亚马逊 Keyspaces

以下代码示例向您展示如何使用 Python 客户端驱动程序和特定服务的证书连接到 Amazon Keyspaces。

from cassandra.cluster import Cluster from ssl import SSLContext, PROTOCOL_TLSv1_2 , CERT_REQUIRED from cassandra.auth import PlainTextAuthProvider ssl_context = SSLContext(PROTOCOL_TLSv1_2 ) ssl_context.load_verify_locations('path_to_file/sf-class2-root.crt') ssl_context.verify_mode = CERT_REQUIRED auth_provider = PlainTextAuthProvider(username='ServiceUserName', password='ServicePassword') cluster = Cluster(['cassandra.us-east-2.amazonaws.com'], ssl_context=ssl_context, auth_provider=auth_provider, port=9142) session = cluster.connect() r = session.execute('select * from system_schema.keyspaces') print(r.current_rows)

使用说明:

  1. "path_to_file/sf-class2-root.crt"替换为第一步中保存的证书路径。

  2. 按照中的步骤,确保ServiceUserNameServicePassword与您在生成服务特定凭证时获得的用户名和密码相匹配生成特定服务的凭证

  3. 有关可用终端节点的列表,请参阅Amazon Keyspaces 服务端点

使用 Apache Cassandra 的 DataStax Python 驱动程序和 SigV4 身份验证插件Connect 亚马逊 Keyspaces

以下部分介绍如何使用 Apache Cassandra 的开源 DataStax Python 驱动程序的 Sigv4 身份验证插件来访问亚马逊 Keyspaces ace(适用于 Apache Cassandra)。

如果您尚未执行此操作,请按照步骤为您的 IAM 角色创建凭证如何创建和配置AmazonAmazon Keyspaces 凭证。本教程使用临时证书,这需要 IAM 角色。有关临时凭证的更多信息,请参阅使用 IAM 角色和 SigV4 插件的 Amazon Keyspaces。

然后,从GitHub 存储库将 Python Sigv4 身份验证插件添加到您的环境中

pip install cassandra-sigv4

以下代码示例显示了如何使用适用于 Cassandra 的开源 DataStax Python 驱动程序和 Sigv4 身份验证插件来连接亚马逊 Keyspaces。该插件依赖Amazon SDK for Python (Boto3)。它boto3.session用于获取临时证书。

from cassandra.cluster import Cluster from ssl import SSLContext, PROTOCOL_TLSv1_2 , CERT_REQUIRED from cassandra.auth import PlainTextAuthProvider import boto3 from cassandra_sigv4.auth import SigV4AuthProvider ssl_context = SSLContext(PROTOCOL_TLSv1_2) ssl_context.load_verify_locations('path_to_file/sf-class2-root.crt') ssl_context.verify_mode = CERT_REQUIRED # use this if you want to use Boto to set the session parameters. boto_session = boto3.Session(aws_access_key_id="AKIAIOSFODNN7EXAMPLE", aws_secret_access_key="wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY", aws_session_token="AQoDYXdzEJr...<remainder of token>", region_name="us-east-2") auth_provider = SigV4AuthProvider(boto_session) # Use this instead of the above line if you want to use the Default Credentials and not bother with a session. # auth_provider = SigV4AuthProvider() cluster = Cluster(['cassandra.us-east-2.amazonaws.com'], ssl_context=ssl_context, auth_provider=auth_provider, port=9142) session = cluster.connect() r = session.execute('select * from system_schema.keyspaces') print(r.current_rows)

使用说明:

  1. "path_to_file/sf-class2-root.crt"替换为第一步中保存的证书路径。

  2. 确保 aws_access_key_idaws_secret_access_keyaws_session_tokenSession Token你使用获得的Access KeySecret Access Key、和相匹配boto3.session。有关更多信息,请参阅中的证书Amazon SDK for Python (Boto3)

  3. 有关可用终端节点的列表,请参阅Amazon Keyspaces 服务端点