问题标签 [cassandra-python-driver]

我刚刚通过 Docker 创建了两个 Cassandra 集群。该docker exec -it name nodetool status命令告诉集群创建一切正常：

然后我将尝试从 Python 驱动程序将数据插入到表中。

这是我的代码：

最后，当我尝试执行代码时，我在终端中给出了以下错误：

我尝试在 Python 驱动程序中使用 BATCH 将 150.000 个生成的数据插入 Cassandra。大约需要30 秒。我应该怎么做才能优化它并更快地插入数据？这是我的代码：

Is there a way to find out which node was contacted first during the initial setup by the driver? For example, is there a way to find the host 10.9.58.64 that was contacted?

我想使用python driver执行多个 cql 语句（2 个或更多）。

我尝试了这样简单的代码，但如果查询包含多个语句，则会导致错误。我不想拆分语句或格式化它（单个语句）。我只想执行整个 CQL。

如何使用 Cassandra 的 python 驱动程序来做到这一点 - 有可能吗？

我使用;as 语句拆分。

它会产生这样的错误：

我正在使用 python 程序将 250 万条记录写入 Cassandra。程序完成很快，但在查询数据时，记录会在很长一段时间后反映。记录的数量逐渐增加，似乎数据库正在以队列方式执行对表的写入。写入继续进行，直到所有记录完成。为什么写反映迟？

我想使用来自DataStax Python Driver for Cassandra DB 的 ORM（使用数据创建一些类并自动从中创建一个表，而无需编写太多 CQL = ）

我已经通过 docker 在 localhost 上部署了一个 Cassandra 服务器，并尝试像他们的手册中所写的那样做：

但是，唉，sync_table(...)给我一个错误：

我该如何解决？

我在 linux 系统上使用 cassandradb 和 datastax python 驱动程序。通常在使用其他数据库时，我发现在与 unix 兼容的系统上，通常有一种方法可以通过 unix 套接字建立与数据库的连接，而不是使用环回接口。通过套接字连接，您可以完全绕过操作系统网络堆栈，结果通常是更好的性能。

我很确定 cassandra 支持这一点，至少因为cassandra pip 包UnixSocketEndPoint的模块中有一个类。cassandra.connection这个类是在 github repo 中实现的，但是没有任何关于如何使用它的文档。有人用这个吗？如何使用 python API 配置与 cassandra 的 unix-socket 连接？

我设法从github 上的 cassandra python 驱动程序测试中找到了以下代码片段：

这实际上是我正在寻找的大部分内容。我只是对如何将 cassandra 配置为通过套接字而不是 TCP 进行侦听感到困惑。还是 cassandra 有默认的套接字路径？

提前谢谢了。

我在自定义服务器上的 docker 容器中运行 cassandra。

我像这样启动 cassandra docker：

当我想通过 datastax 中的 python cassandra 驱动程序连接到服务器时，如下所示：

抛出异常：

经过数小时搜索 docker 网络权限后，我找到了简单的解决方案，所以也许这对您也有帮助。