问题标签 [cassandra-driver]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
224 浏览

python - 防止 Cassandra Query 从缓存中受益

我正在尝试为我的 Cassandra 集群获取一些指标。因此,我想看看查询在第一次运行时的执行情况,而没有缓存的好处。有没有办法在每个查询的基础上禁用缓存,如果没有,是否可以在每个表的基础上禁用它?

对于有问题的表,它是使用缓存属性创建的

但根据输出,同一查询的后续问题显然正在获得缓存优势。

0 投票
2 回答
495 浏览

node.js - 在 Node.js 脚本中完成 Cassandra 后,我真的需要调用 client.shutdown() 吗?

我一直在尝试通过 Datastax 查找有关与 Node.js cassandra-driver 相关的 Cassandra 会话的信息。我读到一些内容说 cassandra-driver 自动管理会话并且我不需要调用 client.shutdown()。

我正在寻找有关 cassandra-driver 如何管理会话的一般信息,如何查看所有活动的 Cassandra 会话,我是否需要调用 shutdown() 或者每次脚本运行时都必须重新打开会话会适得其反?

基于“pm2 info”,我没有看到大量的活动句柄,所以我认为没有发生任何问题,但我可能弄错了。对于一个小脚本(85mb)来说,Ram 的使用似乎有点高。

0 投票
1 回答
243 浏览

python - cassandra python " item = val[i] " 想不通

我是 cassandra python 模块的新手。所以我正在尝试使用批处理语句将 json 文件插入到表中。但我收到“KeyError:0”错误。我知道提供的文件太多了。但我几乎尝试了所有东西,但不明白我的错误。请帮忙!!!!!!

这是产生的错误:

这是 json 文件的格式,因为它包含机密信息

这是 cqlsh 中的创建表查询

0 投票
0 回答
20 浏览

python - 如何在 cassandra 中声明地图定义类型的列表

我想在 cassandra 中声明一个对象列表,并且我已经创建了类型对象

如何声明地图教育类型列表,因为我有一个这种格式的 json 文件:

0 投票
1 回答
160 浏览

c# - C# DataStax 驱动程序中的 CassandraEntityBase

我有一个 .net 核心应用程序,它通过 DataStax 驱动程序将数据保存到 Cassandra 实例。

我的 Cassandra 实体有一个基类。现在,如果我想将我的 TimeUUID 类型 id 带入这个基类,插入时会出现错误:

同样的方法适用于 EntityFramework。而且问题不在于我的表、连接或键空间,因为当我将 id 字段带回实体本身时,它可以工作。

我的插入方法

我的基类

继承基类的实体类

你能告诉我什么是问题吗?有没有办法声明 CassandraEntityBaseClass ?

0 投票
0 回答
82 浏览

c - Not able to insert timestamp data in Cassandra from C program

I have a simple code written in C for inserting local date and time into Cassandra's timestamp column as follows:

But this code is not able to insert anything inside time_table. If I try to insert the same thing using cqlsh using the query insert into time_table(id,time) values(now(),'2019-09-04 10:59:22');, then the values are getting inserted without any problem. I am using Cassandra driver for C version 2.13.

Can anyone please point out the mistake in the code?

0 投票
1 回答
48 浏览

c - 无法使用 Cassandra 的 C 驱动程序连接到键空间

我有以下代码用于插入 Cassandra 的简单查询。我在这里尝试使用准备好的语句,因为常规语句无法在表的时间戳列中插入时间戳time_demo

在最后一行之后,我的程序突然结束。我想在test_keyspace使用准备好的语句的同时连接到键空间。我猜该程序因此而被终止,因为我没有为它正确编写代码。

谁能指出我在这里犯的错误?我正在为 C 使用 Cassandra 2.13 驱动程序。

0 投票
2 回答
320 浏览

node.js - 为异步操作暂停 cassandra 流

我想在处理下一行之前暂停我的 cassandra 流以进行一些异步操作。

每一行都在一个可读的事件侦听器中接收。我试过使用 stream.pause 但它实际上并没有暂停流。我也在“数据”事件侦听器中尝试过同样的方法,但这也不起作用。也许会非常感谢您的见解和解决方案。这是我的代码。在可读和“等待”中使用 async 使用 await 实际上并不能阻止下一行在异步函数完成之前出现。

//下面的不行

0 投票
2 回答
281 浏览

javascript - 更新计数器时 Cassandra Node.js 驱动程序内存泄漏

尝试迁移计数器表。从源表中读取每一行并将结果写入新表。当使用 js 写入数百万行时,堆内存不足。同步代码被用于确保在尝试写入另一行之前写入行。确定观察堆的问题似乎是在使用cassandra-driver执行UPDATE查询时堆上升。

在这种情况下如何避免内存泄漏?

0 投票
1 回答
1305 浏览

java - Cassandra - 写入错误。如何解决?

在我们公司,我们做一个项目,使用 apache,Cassandra。直到最近,我们还使用了一个较旧的驱动程序。昨天,我们尝试用最新的 4.3.0 替换它。我们连接到数据库,一切正常。问题是当我尝试替换 ear 文件或添加另一个使用相同代码的子项目时。

此时,我收到此错误。

我试图在互联网上寻找这个问题,研究他们的文档。我没有找到解决方案。

我连接到数据库的非常基本的代码。

我使用wildfly作为服务器。当我替换 ear 文件或添加另一个具有相同代码的文件时,我收到错误消息。

关于如何解决它的任何想法?