问题标签 [datastax-python-driver]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
428 浏览

python - 如何在 Cassandra 中正确配置和执行 BatchStatement?

在我的Python ( 3.8 ) 应用程序中,我通过DataStax Python Driver 3.24向Cassandra数据库发出请求。

根据官方文档,我尝试通过BatchStatement使用单个查询执行几个 CQL 操作。不幸的是,我的代码导致以下内容出错:

从我的代码中可以看出,我在reply_policy里面设置了属性的值BatchStatement。无论如何,我的代码会引发您在上面看到的错误。财产内部必须有什么样的价值reply_policy?当前冲突的原因是什么?

代码片段

0 投票
0 回答
140 浏览

amazon-web-services - 如何使用 datastax 驱动程序改善连接到 Cassandra 集群的速度太慢?

我最近在同一个内部网络中建立了一个Cassandra ( 3.11.10) 集群,其中AWS EC23实例上的节点具有相同的硬件配置。他们每个人都看到了对方。通过登录它们中的每一个,您可以访问 Cassandra 数据库中的表。它与 cqlsh 配合得很好,一切看起来都很完美。3

实例类型t3.medium

亚马逊机器映像 (AMI) : CentOS 8 (x86_64) - with Updates HVM.

顺便说一句,我在每个 EC2 实例中使用了本文中的说明来设置 Cassandra。

我的配置文件 ( /etc/cassandra/default.conf/cassandra.yaml) 如下所示:

经过这些设置后,我注意到与数据库的连接过程需要很长时间(需要超过 5 秒)。我尝试通过名为DBeaverwhich use的 SQL 客户端连接到 Cassandra 数据库Cassandra Java Driver 3.5.5。我还尝试从用 Python 编写的 AWS Lambda 函数连接到 Cassandra 数据库。所以在最后一种情况下,我使用了官方的 Datastax Python Driver

问题:这种奇怪行为的原因是什么?如何改进?

0 投票
1 回答
81 浏览

apache-spark - PySpark 使用 google colabs 连接问题连接到 Cassandra

我想使用 google colabs 的 pyspark 连接到 cassandra。我已经编写了以下代码,下载了 spark 文件并使用 java 将其设置为路径变量。以下是代码:

当我执行它时,它会创建上下文会话,但会显示“org.apache.spark.sql.cassandra”这个错误。我想我必须单独下载连接器并包含在我的路径中,或者我已经包含在我的路径中。如果有任何解决方案请帮忙。这是在谷歌colabs

0 投票
1 回答
89 浏览

python - 在 wait() 上使用 Python 多处理库错误的并行 Cassandra 请求

我写了一段多处理代码。连接到我正在运行 32 个查询以获取数据的 cassandra。我试图使用 python 中的多处理库来并行化获取。代码看起来像这样。

在运行程序时,它在 wait() 上出错

0 投票
0 回答
64 浏览

python - Cassandra Python 驱动程序:CRC 不匹配

我在带有 Cassandra 4 数据库的 Python 3.8.10 中使用cassandra-driver (版本 3.25.0)。有时在向数据库发出请求时,我会收到以下错误。我已将相关部分粘贴到下面的堆栈跟踪中。

可能每向数据库发出约 100 个请求就不一定频繁。我在 Cassandra 集群中只有一个节点设置。我不确定为什么 CRC 校验和会失败。