问题标签 [pycassa]

我想查询多个值的索引列族。例如：

所以如果我查询[val1, val2]， then[key1, key3]将被返回。

这可能吗？

使用 pycassa 时如何指定主键SystemManager.create_column_family？

谢谢。

在我的应用程序中，我想获取列族中的所有行，但要忽略暂时不可用的行（例如，某些节点已关闭）。

我有多个节点。如果其中一个节点关闭，get_range则将抛出UnavailableException，我什么也得不到。

我想要的是获取当前可用的所有行，因为对于用户来说，它总比没有好。我怎样才能做到这一点？

• 我正在使用 pycassa。
• 我的列族中的行键就像随机字符串，所以我不能用来get一一获取所有行。

我的脚本是 python，而 cassandra 是数据 stax 社区版。

这是我在尝试插入 cassandra 列族时遇到的错误。

代码是这样的：

x 是“{key:value}”形式的简单数组

错误日志提示：

我在这里似乎很想念一些东西……这就是我来这里问专家的原因！

我有以下 Python 代码，它从 cassandra 数据库中获取数据。我想要实现的是最后有 json 编码的变量。但是，毫不奇怪，我的代码仅将最新数据行附加到变量。

如何将所有数据组合或附加到单个变量？

谢谢

我正在使用 Pycassa 作为库来访问 Cassandra

我有一个与此类似的 Cassandra DB 表：

我使用 Python (Pycassa) 访问我的 Cassandra 数据库。

有没有办法查询数据库以获得出现次数最多的客户端？例如，在这种情况下，它C1与2.

我不确定是否可以使用 Pycassa 直接查询 Cassandra。如果可能的话，我怎么能做到这一点，或者我应该使用其他工具？

谢谢

PS：我需要使用nosql，所以请不要建议我使用关系数据库。

编辑：我开始工作了，我进入 pycassa 目录并输入python pycassaShell，但我的问题的第二部分（在底部）仍然有效：如何在 pycassaShell 中运行脚本？

我最近安装了 Cassandra 和 pycassa 并按照此处的说明进行操作。

它们工作正常，除了我无法加载 pycassaShell。当我pycassaShell在命令提示符下键入时，我得到

我需要为它设置路径吗？

另外，有谁知道您是否可以使用 pycassaShell 运行 ddl 脚本？正是出于这个原因，我想尝试一下。目前，我正在 cassandra CLI 中执行所有 ddl，我希望能够将其放入脚本中以使其自动化。

.我正在尝试使用 pycassa 加快插入 Cassandra 的速度。我听说使用多线程和打开多个连接可以大大加快速度。我正在插入大量 json 格式的推文。我的代码在这里工作了一段时间，然后线程开始抛出异常并停止，似乎我拥有的线程越多，它停止工作的速度就越快......我猜问题是与 cassandra 的连接，有点做连接池。有任何想法吗？

编辑：所有线程都抛出“线程 Thread-3 中的异常（很可能在解释器关闭期间引发）：”

为了让 Cassandra 插入更快，我正在使用多线程，它工作正常，但是如果我添加更多线程它没有任何区别，我认为我不会产生更多连接，我想我可能应该使用池。 execute(f, *args, **kwargs) 但我不知道如何使用它，文档很少。到目前为止，这是我的代码..

这只是另一个文件..

我是一名实习生，没有太多经验，所以我相信你们可以在这里帮助我。我从 google 获得了所有类型的 nodetool 语法，但我不确定如何使用它以及何时应该使用它。我的 3 节点集群仅在环上显示 1 个节点。所以我将告密者更改为 rackInferring 并重新启动 cassandra。现在我必须运行 nodetool repair 吗？如何？