datastax 相关问题

如何使用 Cassandra Python 驱动程序设置/覆盖客户端请求超时？

我有一个简单的脚本可以将新记录插入 Cassandra 数据库。它在我的本地计算机上运行良好，但是当我将数据库移动到远程 Mac 时，我收到来自客户端的超时错误...

如何在多应用场景下获得Cassandra Writes的背压？

我有多个应用程序写入 Cassandra。 每个单元应用程序都配置了反压机制，例如吞吐量MBPerSec = 10 当多个应用程序同时运行时就会出现问题

从 gremlinpython 中的另一个现有边更新边属性

我正在尝试通过提取另一个现有边缘的属性来更新我的 dse 图中的边缘，如下所示： edgeProperties = g.E(edge.id).valueMap().next() g.V(newVertex.id).as_('newV').addE(edge.label)...

Cassandra 一致性 ONE 更新所有副本

我正在 Cassandra 中更新一条记录，我已在 cqlsh 会话中将一致性设置为 ONE。我已启用跟踪来分析写入性能。 使用复制创建键空间 jesi = {'cl...

通过 stargate API 在 Cassandra 表上使用 $in 运算符

我有一个 Cassandra 表，它包含一个名为“marks”的列。它不是主键的一部分。 现在，我希望运行这样的操作： select * from mytable WHEREmarks in (58,88); 如何实现...

在不同节点同时插入2条具有相同主键的行，写入时间会发生什么变化？

我想知道 cassandra 中使用的一致性级别是否对 WriteTime（在 cassandra 中插入/更新单元格的时间）有影响。 语境 如果你有下表... 如果不是 EXI，则创建表...

无法使用Python驱动程序连接到Astra DB

我相信我正在按照Python-driver-AstraDB文档中提到的方式进行操作 云配置= { 'secure_connect_bundle': 'secure-connect-test-warehouse.zip' } 日志记录.basicConfig（级别=

如何在 Stargate 容器中启动 CDC 代理？

我正在尝试为 Datastax CDC 构建集成测试。我正在尝试按照此处的说明创建一个运行 CDC Java 代理的容器化 Stargate 实例。我正在使用以下做...

如何使用 REST API 查询 DataStax Astra 中的表以过滤结果？

目前，我在 DataStax Astra 中使用 Rest API 时遇到问题。 例如数据： { “计数”：2， “成员”：[ { “创建时间”：“”， “

如何为 TLS 配置 datastax zdm 代理？

我的一位客户正在使用开源零停机时间 (ZDM) 迁移工具 https://github.com/datastax/zdm-proxy.git 将当前的Cassandra集群拆分成多个集群。 第一题...

如何在 Nifi EvaluateJsonPath 中使用动态属性？

目前，我正在构建第 3 方自动数据收集过程，通过自动运行的 nifi 将数据同步到 datastax Astra。这是我从第三方获得的示例 api 返回。 { ...

具有嵌套 UDT cassandra 的模型压力测试

我有嵌套 UDT 的模型。如何对模型进行压力测试。 卡桑德拉版本：4.1 我尝试使用将数据类型更改为字符串。但我们可以得出结论吗

集群上的一个节点无法连接到 Datastax Opscenter

Can't connect to Cassandra (All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:9042] Cannot connect))), 稍后重试。

在 Amplify 上构建 Next.js 应用程序时包含压缩的安全连接文件

在 node.js 中有一个用于连接到 Datastax Astra-DB Cassandra 数据库的驱动程序，称为“cassandra-driver”。对于遗留连接它使用名为 secure-connect-{DB-

在 where 子句中找到的 Cassandra 非主键列

所以我是 Cassadra 的新手，遇到了一个问题，所以我有一个 从 id = 1 AND tag = 'sdasd' AND collector = 1 和 end_value > 0 的数据中删除 end_value 不是任何类型的一部分......

使用c#将数据登录到cassandra中

我试图使用c#将数据记录到Cassandra中。所以我的目标是在200ms内记录尽可能多的数据点。我试图节省时间，在200ms内随机键和值。请看代码以供参考。

将Cassandra数据存储到其他分布式文件系统，如MapR和hdfs上是否可行？

我只是想知道将apache Cassandra的数据存储到其他分布式文件系统的影响。比如说，我有一个5节点的Hadoop集群，复制因子为3。

java.io.IOException: 在127.0.0.1:9042处打开连接到Cassandra的本地连接失败。

我找到了一个类似的帖子，但它没有帮助。我已经使用Cassandra工作了一段时间，现在我试图设置spark和spark-cassandra-connector。我正在使用IntelliJ IDEA来做这个工作（...

Cassandra查询令牌函数在输入时给出了No viable alternative的错误。

我试图使用datastax python cassandra连接器对Cassandra表运行以下查询。我得到的是 "没有可行的选择在输入'TOKEN (...ECT TOKEN...)'"错误。是否有什么问题...

java.lang.ClassNotFoundException: com.datastax.spark.connector.rdd.partitioner.CassandraPartition。

我已经使用Cassandra工作了一段时间，现在我正在尝试设置spark和spark-cassandra-connector。我正在使用IntelliJ IDEA来做这件事（第一次使用IntelliJ IDEA和Scala），在 ...