问题标签 [cassandra-driver]

I've installed Cassandra on one EC2 instance that contains one keyspace with SimpleStrategy and replcation factor 1.

I've also made port 9042 accessible from anywhere in the security group.

I have a Node.js application that contains the following code:

which produces the following error:

NoHostAvailableError: All host(s) tried for query failed. First host tried, 12.34.567.890:9042: DriverError: Connection timeout. See innerErrors.

I use cassandra-driver.

I've made sure Cassandra is running.

Edit:

As Aaron suggested, I have installed cqlsh on the client machine. When I go cqlsh 12.34.567.890 9042, it returns:

Connection error: ('Unable to connect to any servers', {'12.34.567.890': error(10061, "Tried connecting to [('12.34.567.890', 9042)]. Last error: No connection could be made because the target machine actively refused it")})

As Aaron suggeted, I have edited Cassandra.yaml on the server and replaced localhost with 12.34.567.890. I'm still getting the same error though.

我正在尝试sync_table使用来自 python Cassandra 驱动程序（包版本 3.14）的对象映射器声明和创建（使用）Cassandra 表cassandra-driver，但我找不到在集合中定义冻结值的方法。

有没有办法使用 Object Mapper 定义冻结，或者我必须手动编写CREATE TABLE语句来执行此操作，然后仅使用 Object Mapper 进行查询？

我正在尝试在 cassandra 中插入地图类型：

代码插入行但显示以下消息：

是什么原因？

我有一个简单的单节点 Cassandra 集群，它具有基本的键空间配置replication_factor=1

在这个键空间中，我们有大约 230 个表。每个表大约有 40 列。我们对这些表的写入速度大约是每天一次在五分钟内写入 30k 次。我有大约 6 个python工作脚本，它们一次对任何一张表进行这些写入，并且它们都将继续进行这些写入，直到当天所有 230 个表都被写入。脚本使用python cassandra-driver一个简单的会话来进行这些写入。就这里写入的数据而言，其中很多是nulls.

实际上，如果我是对的，这可以被认为是 6 个并发连接，每天 5 分钟内产生 30k+ 个条目。

我了解 cassandra 如何写入和删除工作，并且熟悉协调节点等。我正在观察间歇性发生的回溯，如下所述：

我的问题与如何解决这个问题有关。我无法验证问题是出自我的工作人员脚本还是 Cassandra 集群本身。我应该放慢我的工人写作业的速度吗？我应该运行某种诊断来提高 Cassandra 的性能吗？

到目前为止，我读过的所有解决方案都与多节点集群有关，而我找不到适用于单节点集群的解决方案。

我觉得我们的集群不健康，我的努力应该针对那里的修复。如果是这样，我不确定从哪里开始。谁能指出我正确的方向？

如果有任何进一步的信息我可以提供帮助，请告诉我。

我正在使用 cassandra-driver-core 版本 3.5.1

我在卡桑德拉有一张桌子。表中的所有字段都是驼峰式的，并用双引号创建。这些字段需要采用驼峰形式，因为我的 solr 模式具有驼峰形式，并且我们有大约 80-120 个字段。

但是当我在这个表中插入我的 json 文档时，使用下面的代码：

生成的插入查询：

cassandra 驱动程序将插入语句中的字段转换为小写，导致以下异常：

在我的表字段名称是catalogName

我应该怎么做，以便驱动程序不会小写我的字段？

更新：

我知道我可以创建如下查询：

创建时fieldNameList我可以在字段名称中添加引号。

还有其他解决方案吗？

我必须从 Cassandra 数据库中读取 3 TB 的生产数据。

我已经使用 java 驱动程序实现了分页，但是这种技术使用偏移值，这意味着我要重新跟踪我的数据以到达特定的行，并且这个过程使用的是堆内存，这不是一个好习惯。我想在不使用大量堆内存的情况下读取数据

通常，我想批量获取 10000 行，然后再次读取下 10000 行，而无需再次读取前一万行

我不需要高读取延迟我唯一的问题是在不消耗大量堆内存的情况下读取数据......

这是我的部分代码 Statement select = QueryBuilder.select().all().from("demo", "emp");

这就是我分页的方式

其中 100001 是我想要输出行的起始值，而 25000 是页面的大小。所以在这里我必须先达到 100000，然后我将打印第 100001 个值。这导致了我的堆问题，而且在我的情况下，我不想到达一个页面的末尾以获得另一页的第一条记录。

所以，我正在用 python 构建一个应用程序，它从 twitter 获取数据，然后将其保存到 cassandra。我目前的问题在于一个脚本，它从 kafka 读取数据并尝试将其写入 cassandra，如下所示：

我试图将测试消息插入到表 twitter.mensaje_73 中，它运行良好，如下所示：

任何帮助将不胜感激:)

我正在尝试使用 dockers 在 cassandra 上工作，而且我需要 Python 来使用它。我尝试使用 pip 命令为 Python 安装 cassandra-driver。但是为python2.7安装了驱动程序，但我可能需要为python3安装驱动程序。当我使用命令时： sudo pip3 install cassandra-driver 出现错误。但是 sudo pip install cassandra-driver 没有给出任何错误并且它被安装了。

我试图查看 pip3 文件以进行更改，但不确定要更改哪一个。看起来不错。

我正在循环中在 cassandra 中进行查询，有时在 C++ 客户端中出现错误“所有 I/O 线程上的所有连接都忙”。负载也很低。 服务器版本- apache-cassandra-3.11.2 驱动版本- c++ 驱动版本 2.7 相关客户端驱动配置 - cass_cluster_set_max_connections_per_host (cluster, 20 ) cass_cluster_set_core_connections_per_host(cluster,2) cass_cluster_set_num_threads_io(cluster,2)

我是卡桑德拉的新手。我创建了一个示例表。现在在插入过程中面临问题。

创建的员工如下：

书面查询：

我被困在这一点上。