问题标签 [amazon-keyspaces]

我刚刚开始学习 AWS。基本上，我只想知道 AWS 如何与 Apache 和 Datastax Cassandra 兼容和使用。对于 Cassandra，AWS 需要学习的所有内容。此外，如果我在 AWS 上运行 Cassandra，则需要学习 AWS 内部架构，或者如果有人可以提供帮助，则只需概述一下，将不胜感激。

在 AWS 上的 Amazon Keyspaces 上，我无法截断我的表。你知道为什么吗？该指令似乎存在于 CQL 上，但即使在 MCS 上的 CQL 编辑器上也不起作用。

我最近开始使用 AWS 的 Cassandra Managed Service 产品，并尝试以编程方式连接到 AWS 在其文档中显示的示例密钥表。我已经下载了 Cassandra c# 驱动程序并获得了生成的服务凭据。我现在遇到的问题是连接到集群（cluster.Connect()）。我尝试在 .Connect 中使用各种不同的集群名称，但没有运气。任何人都知道集群名称应该是，或者在哪里可以找到它？另外，还有什么我没有的吗？这是否需要 TLS 连接编程才能工作？

我收到的错误是“找不到主机”：

错误信息：

尝试查询的所有主机都失败（尝试了 3.17.137.4:9042: SocketException '连接尝试失败，因为连接方在一段时间后没有正确响应，或者建立连接失败，因为连接的主机没有响应。'）

堆栈跟踪：

我在从 Lagom 环境连接到 AWS Managed Cassandra 服务时遇到问题。这是我尝试过的，结果如何。

(1) Amazon 提供了从 Java 代码连接 AWS MCS 的说明：

https://docs.aws.amazon.com/fr_fr/mcs/latest/devguide/cqlsh.html#using_java_driver

说明的要点是您需要安装证书，然后将其传递给 JVM，如下所示：

然后，您可以使用您选择的任何 Cassandra Java 驱动程序。我的选择是 Lagom 框架提供的 DataStax 驱动程序。

我通过将以下内容添加到build.sbt：

(2) 在将我的 Lagom 应用程序部署到 AWS 之前，我想在开发模式下使用它，但将它连接到 AWS MCS 而不是嵌入式 Cassandra 服务器。Lagom 提供了在开发模式下执行此操作的说明：

https://www.lagomframework.com/documentation/1.6.x/scala/Cas​​sandraServer.html#Connecting-to-a-locally-running-Cassandra-instance

说明的要点是将以下几行添加到build.sbt：

此示例中的 URI 假定 Cassandra 服务器在localhost:9042. 就我而言，我将其替换为cassandra.us-east-1.amazonaws.com:9142.

(3) 然而，当我运行时sbt runAll，我在尝试访问 AWS MCS 时遇到超时：

(4) 我通过完全绕过 Lagom 并且只编写了一段非常简单的代码来隔离问题，如下所示：

这很简单。但是会发生同样的超时。我究竟做错了什么？

我可以使用以下代码片段连接到 AWS Managed Cassandra Service。

在将 Stream POJO 写入 Cassandra 时，我遇到了以下异常。

com.datastax.driver.core.exceptions.InvalidQueryException：此操作不支持一致性级别 LOCAL_ONE。支持的一致性级别是：LOCAL_QUORUM

通过使用以下代码段设置 ConsistencyLevel = LOCAL_QUORUM，我能够在另一个项目中解决此问题（不使用 flink）。

当我在 flink 中尝试相同时，我收到以下错误：

线程“主”org.apache.flink.api.common.InvalidProgramException 中的异常：com.datastax.driver.core.QueryOptions@130161f7 不可序列化。该对象可能包含或引用不可序列化的字段。

有什么，我错过了吗？请详细说明如何使用 Flink Cassandra 连接器连接/写入 MCS。

PS：

1. 我使用下面的命令来创建键空间。

2. 我没有在我的代码中使用 AmazonRootCA1.pem。

3. 我没有在我的代码或环境中使用 cassandra_truststore.jks。

4. 我已经安装了证书temp_file.der证书，它是按照这些步骤创建的。

5. 我使用的是 Flink 1.8.2，因为这是 Kinesis Data Analytics 中可用的环境版本。

2020 年 7 月 4 日更新

我可以通过为 QueryOptions 创建一个 Serializable 包装器来解决序列化问题。请在下面找到代码片段：

使用此解决方案，我能够在代码中将一致性级别设置为 LOCAL_QUORUM 并在没有任何异常的情况下运行。

但是在写信给 MCS 时，我遇到了同样的错误：

com.datastax.driver.core.exceptions.InvalidQueryException：此操作不支持一致性级别 LOCAL_ONE。支持的一致性级别是：LOCAL_QUORUM

任何帮助将不胜感激！

尝试从 cql 创建会话时出现以下错误，

我使用过Amazon Managed Apache Cassandra 服务

以下是创建会话的代码

我将一致性级别设置为LocalQuorum，但仍然给出上述错误。如果有人知道如何解决，请帮助我们

我正在尝试从 IntelliJ 的 DataGrip IDE 对 Amazon 的 Managed Cassandra 服务执行插入，但是我收到以下错误：

这是由于 Amazon 使用LOCAL_QUORUM一致性级别进行写入。

我尝试CONSISTENCY LOCAL_QUORUM;在运行其他查询之前设置一致性级别，但它返回了以下错误：

据我了解，这是因为CONSISTENCY是 cqlsh 命令而不是 CQL 命令。

我找不到任何方法来从 DataGrip 中设置一致性级别，以便我可以运行脚本并填充我的表。

最终，如果我找不到解决方案，我将使用普通的 cqlsh，但我希望使用 DataGrip，因为我发现它很有用并且已经配置了许多数据库。我希望有人能对这个问题有所了解，这似乎应该是一个基本功能。

我正在尝试设置 JanusGraph 以访问 Amazon MCS。基础设施都允许访问，但我在配置步骤中遇到了困难。

这是我设置的配置janusgraph-cql.properties：

Amazon MCS 公开端口 9142，而不是 9402。

当我开始时gremlin-server.sh，我可以看到以下输出：

尽管我已将端口设置为 9142，但仍在添加具有端口 9042 的新 Cassandra 主机，导致进程失败（因为 9042 不可用）。有什么我做错了吗？

我正在尝试使用 Perl 连接到 AWS Managed Cassandra。由于一个模糊的错误，它不起作用Error 0: Internal Server Error。

使用DBD::Cassandra库，我可以连接到自托管的 Cassandra 集群，但不能连接到 AWS Cassandra。我认为我的 AWS Root CA 是正确的，因为它通过openssl s_client -connect cassandra.us-east-1.amazonaws.com:9142

来自连接的错误响应是

我也可以使用cqlsh客户端连接并验证连接详细信息是否正确。

任何提示或工作示例都会非常有帮助。

正在寻找使用 AWS Lambda 连接到 Amazon Keyspaces (AWS Managed Cassandra) 的示例程序，但是找不到任何相同的示例程序。