问题标签 [datastax-python-driver]

我有代码

此代码工作正常，它也创建了记录。当我检查记录数时，它匹配 3 个表，但对于test.student_to_class_mapping，它必须是 100，但它只给出1.

我发现了这个问题，逻辑上它是正确的，唯一的问题是clusturing_key在test.student_to_class_mapping.

cassandra.util.uuid_from_time(time.time())无法Unique为每条记录生成 uuid。我可以使用uuid1，但我已经面临uuid1.

我知道，我们可以使用now()，我将代码更改为

现在它工作正常并按照逻辑创建所有记录。

我想知道，有什么方法可以使用now()Model的create方法吗？

在正常情况下，我一直收到此错误。我正在使用 Python Cassandra 驱动程序 (v3.11) 在启用 RPC 的情况下进行本地连接。问题在一段时间后出现。你的假设是它与最大连接数或查询数有关。任何有关从何处开始故障排除的指示将不胜感激。

我正在尝试获取 cassandra 集群的健康状况，有没有办法使用 python CQL 驱动程序来获得它？

我之前使用 pycassa 用于基于节俭的数据模型：https ://github.com/datastax/python-driver

有没有办法使用 CQL python 驱动程序获取集群健康或 get_endpoints

我正在尝试使用官方 python 驱动程序运行 cqlsh 查询：

我收到以下错误：

我试图增加读取超时

尝试#1：

尝试#2：

两种方式都给了我相同的读取时间错误如何正确增加读取超时？

版本信息：

我正在为 Apache Cassandra 使用插件 DataStax Python 驱动程序。

我想从数据库中读取 100 行，然后在更改一个值后将它们再次插入数据库。我不想错过以前的记录。

我知道如何获取我的行：

我知道如何将新行插入数据库：

我的问题是：

1. 我不知道如何连续更改一个值。
2. 我不知道如何在不使用 CQL 的情况下将行插入数据库。我的 columnfamily 有 150 多个列，在查询中写下它们的所有名称似乎不是一个好主意。

总结一下：有没有办法获取行，从每个行中修改一个值，然后将这些行插入数据库而不只使用 CQL？

我正在开发一个简单的 python 模块，它从 tsv 文件中读取数据并将它们加载到 Cassandra 键空间表中。

我从查看 Datastax 给出的示例开始，一切似乎都很好，所以我开始编写代码。

该程序正确地从 tsv 文件中读取数据，并将它们转换为行列表，并且我验证了每一行的每个元素都具有目标列的正确类型。但是当我尝试将原始数据插入表格时，终端会说：

AttributeError：“浮动”对象没有属性“编码”

这是代码：

为了解决问题，我进行了很多更改，但我遇到了新问题，或者与“int”而不是“float”相同。我还在这里阅读了其他问题，并尝试在prepared.bind（）中使用str（row）和repr（row），但我遇到了其他错误。

我是 Python 新手，找不到其他解决方案，你会怎么做？

提前致谢！

编辑 对不起，我忘了提供有关数据库表的详细信息。这是创建语句：

)

我要做的是加载一个 CQL 文件以重新初始化（删除和创建）键空间中的所有表。

我在https://datastax.github.io/python-driver/上搜索了文档，但没有找到任何直接的方法来完成此操作。

SOURCE 不起作用，因为它是一个 cqlsh 命令。我尝试将文件作为输入读取并运行，但遇到错误，因为 execute() 只运行一行。我的最后一个选择是解析文件并运行每个 CQL 命令，但这对于一个简单的请求来说很麻烦。

目前，我得到的最接近的是在读取期间执行文件，如下所示。由于分号，这是我遇到 EOL 问题的地方。

我需要使用 Cassandra 的 Python DataStax 驱动程序插入大量数据。结果我不能使用 execute() 请求。execute_async( ) 要快得多。

但是我在调​​用 execute_async() 时遇到了丢失数据的问题。如果我使用 execute()，一切正常。但是，如果我使用 execute_async()（对于 SAME 插入查询），我的请求中只有大约 5-7% 正确执行（并且没有发生任何错误）。如果我在每个 1000 个插入请求之后添加 time.sleep(0.01)（通过使用 execute_async()），就可以了。

没有任何数据丢失（案例1）：

没有任何数据丢失（案例2）：

数据丢失：

有什么理由可以吗？

集群有 2 个节点

[cqlsh 5.0.1 | 卡桑德拉 3.11.2 | CQL 规范 3.4.4 | 本机协议 v4]

DataStax Python 驱动程序版本 3.14.0

蟒蛇 3.6

我正在使用 Datastax Cassandra python 驱动程序的 Object Mapper 在运行时定义 cassandra 表列（要求类似）。表和列名称以及列类型在运行时解析。

我正在尝试在运行时使用“类型”定义一个 cassandra cqlengine 模型来定义一个类。

看起来在 python 驱动程序中定义的模型类已经向模型添加了一个元类

@six.add_metaclass(ModelMetaClass)
类模型(BaseModel):
...

有没有办法使用类型定义模型？我在定义模型类时看到以下错误

下面是我的 python 代码，我从 CSV 文件中读取密钥并在数据库中删除它们。它运行良好一段时间并抛出这个超时错误。我没有看到任何 GC 问题，并且节点的运行状况正常。

蟒蛇代码：