我正在尝试执行多进程以从 Cassandra 中提取数据。但是，我面临着这个问题。我想使用我的 Cassandra 我的 cassandra_db 类提供的多进程将其拉取为单个键或多个键

我的呼叫班

错误：

我试图执行 2 个键，但面临问题。有谁能帮我解决这个问题

我正在尝试cassandraDB使用 python 连接。我已将身份验证用作PlainTextAuthProvider. 这是我的代码片段。

它抛出以下错误：

未发送身份验证质询，这是可疑的，因为驱动程序需要身份验证（已配置身份验证器 = PlainTextAuthenticator）

我正在尝试sync_table使用来自 python Cassandra 驱动程序（包版本 3.14）的对象映射器声明和创建（使用）Cassandra 表cassandra-driver，但我找不到在集合中定义冻结值的方法。

有没有办法使用 Object Mapper 定义冻结，或者我必须手动编写CREATE TABLE语句来执行此操作，然后仅使用 Object Mapper 进行查询？

我们在更改表格时遇到了一个奇怪的问题。我们使用 Cassandra python 驱动程序 sync_table() 方法从我们的模型（在 py 文件中定义）同步到 Cassandra。集群是一个 20 个节点，压力很大（所有节点的最大使用率在 50-70% 范围内）。

当使用 Cassandra python 驱动程序同步模式时，它在内部执行“ALTER TABLE ADD”命令。在一个特定的表中，当我们添加七个新列时，我们注意到了这种奇怪的行为

• DESCRIBE TABLE 命令显示新创建的 7 列中的 3 或 4 列。有一次，它在 DESCRIBE TABLE 输出中显示了所有 7 列。

  • 但在 select * 输出中，未显示新列。

行为不一致。我们手动删除了列，然后重新同步了架构。每次出现问题时，选择命令都不会显示 7 列中的几列。

任何调试此问题的指针？是因为 Cassandra 节点上的压力吗？

我有一个单节点集群，当我执行以下查询时，我收到以下错误，

**

• 错误：

** :

根据 datastax 文档（https://datastax.github.io/python-driver/api/cassandra.html），他们提到write_request_timeout_in_ms在cassandra.yaml

问题：

1）为什么我会收到这个错误？根据我的表 ( issuetable)，我在该分区下只有 84 个条目。

2）这应该在客户端还是服务器端解决？

我正在尝试连接具有不同端口（9042 和 9043）的集群节点，但在这里找不到方法：

cluster = Cluster(['0.0.0.0','0.0.0.0'],port=9042)

我该怎么做？

Python 驱动程序为大结果提供了事件/回调方法：

https://datastax.github.io/python-driver/query_paging.html

此外，还有一个 BatchQuery 类可以与 ORM 一起使用，它非常方便：

https://datastax.github.io/python-driver/cqlengine/batches.html?highlight=batchquery

现在，我需要在 Paged Result 对象的回调处理程序中执行 BatchQuery，但脚本只是停留在当前页面的迭代上。

我猜这是由于无法在线程之间共享 cassandra 会话，而 BatchQuery 和“分页结果”方法正在使用线程来管理事件设置和回调调用。

关于如何神奇地解决这种情况的任何想法？您可以在下面找到一些代码：

这是我在论坛上的第一个问题，如果我的理解有误，请纠正。

我正在从 DS201 执行练习应用程序驱动程序连接。

表如下：

现在我想按照实验室执行一项任务“将新视频插入数据库的 Python 代码”。

我尝试了这段代码并收到错误：

我在下面尝试但失败了：

1. UUIDs.timeBased()

错误：

2. cassandra.util.uuid_from_time

错误：

暂时我已经硬编码了这个值。

数据库成功：

但我想知道这个？

我正在尝试使用 python 驱动程序连接到 Cassandra：

错误：

我还在 yaml 文件中设置了 rpc 地址：0.0.0.0

基础设施：

• Cassandra 是在 Kubernetes 集群之外的 EC2 上运行的单节点集群（开发环境）。
• Python 应用程序在 Kubernetes 集群中运行
• CoreDNS 显示解析名称时没有错误

问题

如果我再次运行代码 - 我不会收到任何错误。因此，我每次第二次建立集群连接 - 我无法连接到任何服务器。

我究竟做错了什么？

Kubernetes 内的 DNS 日志显示没有错误