问题标签 [amazon-keyspaces]

我在亚马逊密钥空间中创建了一个密钥空间（表），并试图将记录从它获取到我在 ubuntu 中运行的 .net 核心应用程序。我提供了所需的所有内容，例如“.pem”文件用户名、密码和 awsEndpoint 作为在 aws 文档中提到Using a Cassandra .NET Core Client Driver to Access Amazon Keyspaces Programmatically

但是，当我运行代码并尝试连接亚马逊密钥空间时，它会引发异常“所有主机尝试查询失败（尝试 3.6.70.143:9142: AuthenticationException '身份验证失败，请参阅内部异常。'） ”。

但相同的代码在 Windows 环境中执行时可以正确执行并返回所需的结果。

假设我们有一个聊天室。每个聊天室都有几个参与者。就我而言，它是一个客户和几个运营商（1 个或多个）。此外，每个聊天室都有自己特定的主题。正如我们在Cassandra数据库中所知道的，需要根据查询来设计表。

假设我有这样的疑问：

1. 获取所有尚未有操作员的开放聊天室的列表。
2. 获取具有特定操作员的所有打开聊天的列表。
3. 获取尚未有操作员的特定主题的所有打开聊天室列表。
4. 获取具有特定操作员的特定主题的所有打开聊天列表。

我知道非规范化对于 Cassandra 来说是正常的。但是，我是否需要为所有这些查询创建单独的表？我还想知道如何检查一个值是否包含在SELECT查询列表中？如您所见，operators在我的案例中，该列具有list数据类型。

在这个特定的时刻，对于前两个查询，我创建了下表：

对于第三个和第四个查询，我只是更改了分区键并添加了theme列。这有多正确？

我已按照此处的说明使用 Terraform 创建了我认为需要的基础架构。但是，尝试连接时出现此错误：

我创建了一个aws_vpc_endpoint_service，所以我很惊讶这不起作用。

我在这里做错了什么？

我正在使用在 AWS EMR 的 Apache Flink 上运行的 AWS Keyspace (Cassandra 3.11.2)。下面的查询有时会引发异常。AWS Lambda 上使用的相同代码也具有相同的异常 NoHost。我做错了什么？

这是我的代码：

CassandraConnector.java：因为 initpreparedStatement 的开销很大，所以我缓存了这个。

CassandraManager.java：我正在对会话对象使用单例双重检查锁定。

应用程序.conf

我需要删除 Cassandra 中的所有行，但TRUNCATE tbl_name由于尚不支持 TRUNCATE api，因此无法使用 Amazon Keyspace 执行。

现在我脑海中浮现的几个想法有点棘手：

解决方案 A

• 选择所有行
• 循环所有行并将其删除（一个接一个或一批）

解决方案 B

• DROP TABLE
• CREATE TABLE 与旧表的结构

你有什么想法让这个过程保持简单吗？

提前 Tnx

我需要建议以正确设计 Cassandra 中的表格。我需要得到所有书籍的排序列表。排序按上次更新日期执行。每次购买特定书籍时，number_of_buyers都会更新该列。另外，我需要更新updated_at列的值。问题是updated_at列clustering key是primary key. 我们无法更新属于主键的列中的值。

另一个例子：

每个聊天室都有最新消息。这些信息总是在变化。如果发生变化，我想将聊天室放在列表的顶部。许多信使的经典行为。

我正在考虑在 DynamoDB 和 AWS Keyspaces 之间进行选择。

我的主要问题仍然是 Dynamo 中的多对多关系。你真的没有太好的选择。要么你为不可变数据做邻接列表......但在大多数情况下，数据会改变。另一种方法是进行 2 个数据库调用，这真的不是很好。第三种选择是一直更新数据，这似乎也是 a** 的一大痛点。对于批量写入，我认为它最多为 25 行。

然而，Cassandra 提供了物化视图，至少我不必自己管理复制。我也可以做 1 个数据库调用来获得我需要的一切。

我对 NoSQL 数据库还比较陌生，所以我可能会遗漏很多东西。

Dynamo 是否有计划添加物化视图，或者有更好的方法吗？

在我看来，这似乎是一个非常好的功能。它甚至不必创建新表，而是在项目列之间进行引用以使其自动更新。

I have a pretty simple AWS Lambda function in which I connect to an Amazon Keyspaces for Cassandra database. This code in Python works, but from time to time I get the error. How do I fix this strange behavior? I have an assumption that you need to make additional settings when initializing the cluster. For example, set_max_connections_per_host. I would appreciate any help.

ERROR:

lambda_function.py:

sessions.py:

我正在从托管的 Cassandra 迁移到 Amazon Keyspace。

一些生产过程使用Cassandra Json Insert. 当我尝试运行其中一个进程将数据存储在 Amazon Keyspaces 中时，我收到以下错误：

我想这个功能在 Amazon Keyspace 中没有启用。在我当地的 Cassandra 上，我没有启用任何使用JSON insert. 有一种方法可以在 Amazon Keyspaces 上启用此功能

我无法使用我的应用程序代码连接到 Amazon Keyspaces cqlsh：

特别令人困惑的是我的设置在过去有效。

我的cqlshrc：

我像这样获取证书：

DNS似乎很好：

我最近从 18.04 升级到 Ubuntu 20.04，这可能会导致问题。

更新：是的，它可能更改了默认 SSL 协议