问题标签 [cassandra-2.0]

我有一个两节点 Cassandra 集群启动并运行，我正在通过 python-driver API 执行构造的 CQL 查询。我正在对我构建的一系列模型进行单元测试，以抽象出大部分 Cassandra API，以方便其他开发人员使用。我的所有测试在单节点集群上测试时都通过了，但是在添加另一个节点后，测试完全不一致，要么失败，要么出错，要么以最小的韵律或理由通过。

我正在比较插入 Cassandra 的对象和由 Cassandra 查询产生的对象self.__dict__ == other.__dict__，因为我根据从 Cassandra 接收到的列值填充类的字段。

我相信我已经隔离了这个问题。在我的种子节点上：

在我的第二个节点上：

，其中第一列是整数 id，第二列是 Pythondatetime对象。我相信正在发生的事情是，当我在 中插入一行时users，该行被插入到第一个或第二个节点上，但是当我尝试从 Cassandra 检索这个对象时，我正在从一个与我刚才不同的节点读取插入，因为 Cassandra 允许这样做。但是，如果我有consistency_level=ALL（它用于我的 python CQL 调用），我不应该接收最新的行数据，而不是最近插入之前的行吗？

更新

请注意，我们特意删除了唯一标识符。

在种子节点上：

在另一个非种子节点上：

在启动并将新节点添加到配置为使用身份验证的 Cassandra 集群时，我得到以下堆栈跟踪：

这是有道理的，因为先前的节点之一已经创建了它。

鉴于system_auth列族已经存在，使新节点联机的正确方法是什么？system_auth此外，随着集群大小的增加，如何满足增加表的复制因子的需求？

I'm fairly new to Cassandra, and have recently implemented a 2-node cluster on Amazon EC2. I have the 2 data nodes, and 1 application server (running .NET 4.0, connecting to the data nodes through the Cassandra driver), all in the same Amazon availability zone.

After a whole lot of tweaking of the security group, I was finally able to get the connection to work by creating an inbound rule on each of the data nodes to allow ALL TCP traffic from the application server. I don't think this is particularly ideal security-wise, even though I don't see it as a huge risk especially since I'm using private IPs.

My question is this, what port is used for the connection between a .NET Cassandra driver, and the cluster? Based on the documentation, I thought that's what the 9160 RPC port was all about, but when I created a rule for that it didn't seem to do anything. I also tried 7199 and 9042 (just based on little tid bits I've found scattered on the internet).

Thanks, Todd

我是 cassandra 的新手，我想在列计数器系列中获取多个行键，就像 MultigetSliceQuery 一样。是否可能？例如我的 colunfamily 定义是

和数据结构是

现在我想使用 multigetslice 查询获取所有行键。可以使用 multiget slice 查询或任何其他查询来获取记录吗？

我在 1a 中使用总共 4 个节点 2 和 2 在新加坡地区的 1b 可用区。现在我只使用 1 个种子。假设它出现故障，那么我该如何恢复我的集群。

或者，假设我将使用 2 个种子节点并且两个节点都将关闭，那么我该如何恢复我的种子节点。

我正在使用带有 ssd 的 I 类家庭实例。

我正在尝试将 xml 文件中的数据直接插入 Cassandra 数据库。它有 1089090 条记录。

我尝试使用 java 务实地阅读它，并在大约 77000 条记录后得到了这个异常。

java.sql.SqlNontrasientConnectionException：org.apache.thrift.transport.TTTransportException

嗨，我是 Cassandra 的新手。我有一个 2 节点 Cassandra 集群。由于前端强加的原因，我需要...

1. 两个节点中每个节点上所有数据的总复制。
2. 最终一致的写入。因此，被写入的节点将立即向前端确认响应。复制时未同步

谁能告诉我这可能吗？它是在 YAML 文件中完成的吗？我知道那里有保持一致性的属性，但我没有看到任何分区器适合我的需要。我在哪里可以设置复制因子？

谢谢

Cassandra 2.06，Oracle Java 版本“1.7.0_51”，Linux Mint 16

我有一个 cassandra 键空间，其中包含大约 12 个相同的表。

如果我将 100,000 行左右的行加载到 Cassandra 中的几个表中，它就可以正常工作。

如果我加载更大的数据集，一段时间后，其中一个表将不再进行查找（并不总是同一个）。

导致“请求未在 rpc_timeout 内完成。”

其中“mid”是主键（varchar）。如果我查看日志，它有一个 EOFException ...大概是它耗尽了一些资源（它绝对不是磁盘空间不足）

我试图向 cassandra 插入一个特定的 timeuuid，而我设法插入一个的唯一方法是使用 now() 函数，因为我假设 now 函数知道数据库喜欢什么格式。

如何为此创建 cqlsh 命令？

目前我有这个：

但是，当我调试 node.js 或任何与 cassandra 接口的程序时，我希望能够 100% 控制我插入的日期以进行测试。

有类似的东西会很好：

没有它崩溃

谢谢！

我正在为 Cassandra 2.0.3 使用最新的 DataStax Java 驱动程序。每次启动应用程序时，我都会收到如下所示的消息：

尽管有消息，驱动程序似乎工作正常。无论如何要摆脱这些消息。我正在使用带有 Oracle Java 版本 1.7.0_45 的 Ubuntu 12.04 LTS。