问题标签 [cqlengine]

我正在尝试在 Cassandra 中创建一个冻结列表，以便我可以将该列用作主键，如果我手动运行查询，我可以这样做，

但我很难弄清楚如何在 Python 中使用 cqlengine 来做到这一点，

我怎样才能使用 cqlengine 完成同样的事情？

编辑：最终代码片段如下所示，

此查询将返回 Blob 字段的 IP 字符串

此查询的 cqlengine 版本是什么？

我们如何使用 Cassandra 对 Django Rest API 进行分页，分页没有偏移量，目前唯一首选的解决方案是在有限制的主键上使用大于（>）或小于（<）。

这在一定程度上会起作用，但前提是我知道当前页面的最后一项或第一项，

• 如果我需要直接从第 1 页移动到第 7 页怎么办？
• 如果我的起始索引在另一个用户会话中被删除怎么办？

嗨，我在 python 中使用 cassandra。我在 cassandra 中有一个表，其中 line_id (uuid) 作为它的主键。我有大约 2000000 条记录（每个分区有一条记录）。当我想获取记录数时：

我收到此错误：

select count(*) from number_partitioned_line同样，当我在razorsql或datagrip中运行查询时，出现超时错误并且无法获得结果。什么原因？

我正在使用 Cqlalchemy 使用 Python 与 Cassandra db 进行交互。在运行应用程序时，我遇到了错误

模型看起来像：

在哪里db = CQLAlchemy()

Cassandra 表 DDL 为：

编辑：我去 cqlengine/models.py 文件级别调试它。我注意到的是所有列都被捕获为tuple

并且 cqlengineattrs通过检查其类型是否为columns.Column.

cqlengine/models.py 的 Github 链接

这就是为什么它实际上无法获得任何列，因此说没有定义主键。

知道为什么将列选择为元组类型而不是 columns.Column 吗？

谢谢

我正在尝试使用 cassandra 并使用 Flask-CQLAlchemy 库编写烧瓶应用程序。当我试图创建我的模型类（学生）的对象时，它给了我一个名为'Student' object has no attribute '_values' 的错误。经历了与我的错误相匹配的多个解决方案，但无法解决这个问题。

以下是包含 python 代码的文件：

这个是index.html文件

错误日志：

在使用 CQLEngine python 库更改 Cassandra 中的模式后，我试图将行插入表中。在更改之前，模型如下所示：

我已将架构更改为此，添加了四列（DSO、节点、公园和商业化）：

然后，我将表格与包含该行的脚本同步

我检查了数据库并创建了四列。现有行的这些字段的值为 NULL（如预期的那样）。

然后我修改了负责插入批处理行的脚本，包括与新字段对应的值。看起来像：

我已经检查过与新字段对应的值不是 None 并且具有正确的类型。尽管如此，它正确插入了所有行，但新字段中的值在 Cassandra 中为 NULL。

批量插入不会返回任何错误。我不知道我是否遗漏了什么，或者我是否需要做一个额外的步骤来更新架构。我一直在查看文档，但找不到任何有用的东西。

有什么我做错了吗？

编辑

在 Alex Ott 的建议下，我一一插入了这些行。将代码更改为：

如果在执行该行之前metrics_by_date.save()我添加了这些打印语句：

输出是：

在新的字段中，我得到了一个 cassandra 对象，但在其他字段中，我得到了它们的值。这可能是一个线索，因为它继续在新列中插入 NULL。

我有一个 Scylla 集群，其中包含 3 个节点和 1 个使用以下查询创建的表

我从应用程序发出以下查询 SELECT * FROM id_features where id in (1,2,3,4...120); 该查询最多可以有 120 个 id。

在最坏的情况下，此查询是否会根据 id 的令牌值联系所有 3 个节点以获取 120 个 id 的数据？或者只联系 1 个节点来获取所有 id 的数据，并且多个节点仅用于高可用性

复制因子、一致性级别和负载平衡策略是否会在决定节点时起任何作用？

如何在 django cassandra 模型中定义 varchar 字段。

本文档列出了所有数据类型，但没有 varchar 类型 https://docs.datastax.com/en/drivers/python/2.5/api/cassandra/cqlengine/columns.html#:~:text=Columns%20in %20your%20models%20map,one%20non%2Dprimary%20key%20column。

我们需要为特定流程保留计数器。后端位于 Cassandra。我们python用作后端和cqlengine驱动程序来与 cassandra 进行通信。

表定义为：

我无法使用 cqlengine为MAX的以下聚合查询创建过滤器/获取。另外我在 cqlengine 中找不到任何可以帮助我创建以下逻辑的函数：

我能够使用以下方式以pythonic方式实现它：

但是如何使用 cqlengine 来实现这一点。这样我就不必整体迭代了ModelQuerySet吗？