本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
先决条件:在上传数据之前必须完成的步骤 DSBulk
在开始本教程之前,您必须完成以下任务:
-
如果您还没有这样做,请注册 AWS 请按照中的步骤进行帐户设置 AWS Identity and Access Management。
-
按照创建和配置 AWS Amazon Keyspaces 的凭证中的步骤创建凭证。
创建JKS信任存储文件。
使用以下命令下载 Starfield 数字证书,并将
sf-class2-root.crt
保存在本地或您的主目录中。curl https://certs.secureserver.net/repository/sf-class2-root.crt -O
注意
您还可以使用 Amazon 数字证书连接到 Amazon Keyspaces。如果您的客户端成功连接到 Amazon Keyspaces,您可以继续这样做。Starfield 证书为使用旧证书颁发机构的客户端提供了额外的向后兼容性。
将 Starfield 数字证书转换为 trustStore 文件。
openssl x509 -outform der -in sf-class2-root.crt -out temp_file.der keytool -import -alias cassandra -keystore cassandra_truststore.jks -file temp_file.der
在这一步中,您需要为密钥存储创建一个密码,并信任该证书。交互式命令如下所示。
Enter keystore password: Re-enter new password: Owner: OU=Starfield Class 2 Certification Authority, O="Starfield Technologies, Inc.", C=US Issuer: OU=Starfield Class 2 Certification Authority, O="Starfield Technologies, Inc.", C=US Serial number: 0 Valid from: Tue Jun 29 17:39:16 UTC 2004 until: Thu Jun 29 17:39:16 UTC 2034 Certificate fingerprints: MD5: 32:4A:4B:BB:C8:63:69:9B:BE:74:9A:C6:DD:1D:46:24 SHA1: AD:7E:1C:28:B0:64:EF:8F:60:03:40:20:14:C3:D0:E3:37:0E:B5:8A SHA256: 14:65:FA:20:53:97:B8:76:FA:A6:F0:A9:95:8E:55:90:E4:0F:CC:7F:AA:4F:B7:C2:C8:67:75:21:FB:5F:B6:58 Signature algorithm name: SHA1withRSA Subject Public Key Algorithm: 2048-bit RSA key Version: 3 Extensions: #1: ObjectId: 2.5.29.35 Criticality=false AuthorityKeyIdentifier [ KeyIdentifier [ 0000: BF 5F B7 D1 CE DD 1F 86 F4 5B 55 AC DC D7 10 C2 ._.......[U..... 0010: 0E A9 88 E7 .... ] [OU=Starfield Class 2 Certification Authority, O="Starfield Technologies, Inc.", C=US] SerialNumber: [ 00] ] #2: ObjectId: 2.5.29.19 Criticality=false BasicConstraints:[ CA:true PathLen:2147483647 ] #3: ObjectId: 2.5.29.14 Criticality=false SubjectKeyIdentifier [ KeyIdentifier [ 0000: BF 5F B7 D1 CE DD 1F 86 F4 5B 55 AC DC D7 10 C2 ._.......[U..... 0010: 0E A9 88 E7 .... ] ] Trust this certificate? [no]: y
-
设置 Cassandra 查询语言 Shell (cqlsh) 连接,并按照使用 cqlsh 连接 Amazon Keyspaces 中的步骤确认您可以连接到 Amazon Keyspaces。
-
下载并安装DSBulk。
要下载DSBulk,您可以使用以下代码。
curl -OL https://downloads.datastax.com/dsbulk/dsbulk-1.8.0.tar.gz
然后解压 tar 文件并将其DSBulk添加到您的文件中
PATH
,如以下示例所示。tar -zxvf dsbulk-1.8.0.tar.gz # add the DSBulk directory to the path export PATH=$PATH:./dsbulk-1.8.0/bin
创建一个
application.conf
文件来存储要使用的设置DSBulk。您可以将以下示例保存为./dsbulk_keyspaces.conf
。如果您不在本地节点上,请localhost
替换为本地 Cassandra 集群的联系人,例如DNS姓名或 IP 地址。记下文件名和路径,因为稍后您需要在dsbulk load
命令中指定这些内容。datastax-java-driver { basic.contact-points = [ "
localhost
"] advanced.auth-provider { class = software.aws.mcs.auth.SigV4AuthProvider aws-region =us-east-1
} }要启用 SigV4 支持,请从下载阴影
jar
文件GitHub并将其放在DSBulk lib
文件夹中,如以下示例所示。curl -O -L https://github.com/aws/aws-sigv4-auth-cassandra-java-driver-plugin/releases/download/4.0.6-shaded-v2/aws-sigv4-auth-cassandra-java-driver-plugin-4.0.6-shaded.jar