问题标签 [cassandra-driver]

如何传递 dict 和 query 参数？

我可以做这样的代码。

如何使用 dict 作为参数以及查询语法是什么？

这不起作用：

你能帮忙处理一下这个基本代码吗 - 看起来有可能，但我不知道有效的查询语法？

融合升级到 3.3.0 后，Cassandra 连接器失败。Cassandra驱动的版本是3.3。堆栈如下所示。

我已经尝试通过更新 guava 和 io.netty 依赖项，但它并没有解决问题。

我正在使用 DataStax Cassandra 驱动程序。在以下（示例）代码之后：

我想记录下我刚刚输入的查询execute()。我已经尝试过使用零件foo_query.get_all_query_traces())所在的not_sure位置。但是，我在那里只看到一个空数组。是否有一些启用查询跟踪的开关？我通过扫描文档索引找不到任何东西。

我已经在单机（Ubantu）中设置了一个 3 节点的 cassandra 集群，我执行以下操作 -

1. 所有三个节点都启动并且应用程序能够创建密钥空间。
2. 关闭三分之一的正在运行的节点，应用程序仍然能够创建密钥空间。

3. 关闭现在 2 个正在运行的节点中的一个节点并立即启动它，现在应用程序无法创建密钥空间，它继续报告（如无限循环）关于 -

   2017-09-25 14:42:40 INFO RequestHandler:561 - 查询创建 KEYSPACE IF NOT EXISTS MYKEYSPACE WITH replication = {'class':'NetworkTopologyStrategy', 'datacenter1':'2'}; 未在 /127.0.0.1:9042 上准备好，在重试执行之前准备好。多次看到此消息很好，但经常看到它可能是性能问题的根源

我的应用程序日志中充斥着这些消息，并导致 java heap out 错误。

注意-我的复制因子为 2，使用的 cassandra 版本是 2.2.6，cassandra 驱动程序是 2.2.0-rc3。当我恢复到 cassandra 驱动程序 2.1.3 时，一切正常，所以只是想知道驱动程序级别方面是否存在一些问题

更多要补充的是，我什至在 cassandra 驱动程序级别调试了代码，发现这是因为 com.datastax.driver.core.Connection 类的以下给定方法 -

因此，在使节点重新联机后（现在运行 3 个节点中的 2 个节点），RequestHandler 继续报告未准备好的查询，因此在进行此调用时重试之前进行准备 -

我正在尝试实现由 Cassandra 支持的分页 REST API。我发现 Cassandra 驱动程序具有分页功能（http://docs.datastax.com/en/developer/java-driver/3.3/manual/paging/）。我用这个功能做了一个简单的实验，它似乎工作。

通过设置适当的页面大小和页面状态，即使重新启动服务器（Web 服务器，而不是 Cassandra 服务器），我仍然可以获得正确的页面。此外，似乎驱动程序将此页面状态和页面大小连同其声明一起发送到 Cassandra 服务器。这些东西是如何工作的？对我来说它看起来很神秘。

我正在使用 python Cassandra 驱动程序来查询数据库。这是我运行的代码：

在输出中，我在单词前面得到了奇怪的 'n's，而换行符曾经是。

例子：

“在寒冷的森林上空，狂风怒吼，没有叶子可吹。”

有没有办法解决这个问题？

我的 python 应用程序使用了 twisted，并在后台使用了 cassandra python 驱动程序。Cassandra python驱动可以cassandra.io.twistedreactor.TwistedConnection作为连接类使用twisted作为查询方式。

TwistedConnection类使用计时器并reactor.callLater检查查询任务是否超时。

问题是当我使用 cassandra ORM ( cassandra.cqlengine.models.Model) 进行查询时。

在twisted.trial单元测试中运行时。使用上述代码的测试总是失败

失败：twisted.trial.util.DirtyReactorAggregateError：反应堆不干净。

然而，在使用此代码的高速公路工人中，工作正常。

TwistedConnection 的 cassandra 驱动程序代码继续调用 callLater，我找不到方法来查找这些调用中是否仍有待处理，因为这些调用隐藏在TwistedLoop类中。

问题：

• 这是处理 cassandra 查询的正确方法吗（这又称为扭曲反应器）
• 如果是，有没有办法解决DelayedCall由 cassandra 驱动程序超时 ( reactor.callLater) 导致的问题。

我需要持续监控 cassandra 数据库表的 2 列值，如果 column1==true 和 column2==true，我需要执行一些操作。

Cassandra-driver 库是否有能力做到以上几点？或任何其他库来执行上述操作？

这是我的场景，考虑我的表有 cloumnsid主键和clusterkey集群键。我想删除一条属于主键的记录并插入具有相同主键但不同簇键的新记录。在这种情况下，由于某些并发性，似乎一直没有发生插入？尝试使用时间戳，但同样的问题。

使用时间戳

表信息：

查询结果：

批处理前选择结果

批后

我有两个疑问。一个给我来自 cassandra 表的第一页，另一个是检索连续页面。第一个是这样的：

连续的是：

其中图像键是第一页上的最后一个。

我在表中有 13 行。第一个查询在 cqlsh 和应用程序上都返回 10（一致性级别 ONE 仅用于开发）。第二个查询仅检索冲突的结果。下面是我在 django 应用程序上的 cassandra 数据库引擎配置：

我使用的 cassandra 版本是 doc-3.0.9，下面是我的虚拟环境 pip 列表：

为什么第二页在应用程序上没有返回任何结果，但在 cqlsh 提示符下返回？