问题标签 [pycassa]

举例说明：

CQL 文档说它可以完成，但在控制台上它说 execute() 得到了意外的关键字参数。

Cassandra CQL 真的支持查询替换吗？

以下将“DoubleType(reversed=false)”打印到控制台；我如何告诉 pycassa 停止这样做？当我更改列时也会发生这种情况。

谢谢

几天来，我一直在使用 Cassandra 实例而无需重新启动，以完成一项简单的存储推文的任务，一秒钟内保存 1-2 次。之后，Cassandra 变得非常慢，我不得不重新启动它。这是卡桑德拉斯现在预期的稳定吗？编写一个守护程序以每天或每天杀死/重新启动它是一个很好的解决方案吗？

我不确定我是否缺少一些编程的基本规则或使用 PyCassa 的一些基本规则！

问题是：我需要查询 cassandra 以显示 column5（列名）值为 5 的所有行。我可以在 for 循环内打印此结果，但不能在外部打印。我目前的代码是：

这行得通，但不起作用的是：

我确实理解某些人，这个问题可能听起来太幼稚了......但相信我，自上周末以来我一直在努力解决这个问题，现在别无选择，我在 Stackoverflow 上！

基本上我问的问题与这个问题相同，但对于 Python Cassandra 库 PyCassa。

假设您有一个复合类型存储这样的数据：

所以，我知道我可以通过执行以下操作轻松地根据复合类型的第一部分进行切片：

但如果我只想要决赛成绩，我会假设我可以这样做：

要得到：

但相反，我得到：

与第一次通话相同。

难道我做错了什么？这应该工作吗？或者是否有一些使用 cf.get(... columns=[('20120216', 'finalscore')]) 的语法？我也试过了，但有例外。

根据http://www.datastax.com/dev/blog/introduction-to-composite-columns-part-1，我应该能够做这样的事情......

谢谢

是否有可能从 Cassandra 中检索随机行（与 Python/Pycassa 一起使用）？

更新：随机行我的意思是随机选择的行！

当通过 Pycassa 从 Cassandra 获取行时，有时会使用TApplicationException: get_slice failed: unknown result].

我无法重现此异常，也找不到有关此问题的任何文档。现在我将 Cassandra 作为单个节点（用于开发）运行，并且总是在发生大量并发请求的上下文中引发异常。我想知道造成这种情况的原因是性能问题还是与其他问题有关（因此我想知道在生产中运行多个节点时它是否会消失？）。

Cassandra 版本为 1.0.7，日志输出如下：

我们目前在 2 个大型 EC2 实例上使用由 2 个 cassandra 节点组成的集群。他们每个人都有大约65G的使用数据。（开发和生产的设置相同）。

我们遇到的问题是在生产写入期间 - CPU 负载变为 40 +（2 核机器），最终机器变得不可用并且需要重新启动。我尝试了多种“调整策略”，例如减少总内存表空间，改变年轻代中伊甸园空间与生存空间的比例，将更大的对象直接从伊甸园空间复制到老一代，优化压缩以更频繁地运行，使用更小的# sstables（我注意到在崩溃期间磁盘利用率几乎为零，所以我试图减轻内存使用量）。

查看 cassandra system.log，我看不到任何错误或警告。崩溃期间唯一显示的是 StatusLogger 输出。

如果我在 Dev 集群上运行写入，一切都运行顺利 - 没有错误，负载最大 1.5-2。如果我重新启动 2 个生产实例，我可以在崩溃发生之前运行一段时间的读写操作，否则假设机器已经运行了 2 天以上，崩溃会在几分钟内发生。

任何建议，想法将不胜感激。

谢谢

该LIKE条件允许我们在 SQL 语句的 where 子句中使用通配符。这使我们能够执行模式匹配。该LIKE条件可用于任何有效的 SQL 语句 - 选择、插入、更新或删除。像这样

与上述相同的操作一样，任何查询都可用于 CLI 中的 Cassandra。

我正在尝试通过 Cassandra 中的列族进行部分搜索，类似于 SQL 查询，例如：SELECT * FROM columnfamily WHERE col = 'val*' 其中 val* 表示至少匹配前三个字符 'val' 的任何值。

我已经阅读了有关 SELECT 函数的 datastax 文档，但似乎找不到对部分 WHERE 标准的任何支持。有任何想法吗？