问题标签 [cassandra-python-driver]

从文档中，有一种方法可以将数据插入表中：

必须在此处说明列名。但是，就我而言，我有一个数据框，它只有一个标题行和一行数据，例如： "sepal_length" : 5.1,"sepal_width" : 3.5,"petal_length" : 1.4 ,"petal_width" : 0.2, "species" : "Iris".

用户将为我的 API 提供信息以连接到他们特定的 Cassandra 数据库表，该表包含存储在数据框中的列名称。如何在不实际硬编码文档中所述的列名的情况下插入数据框的数据相对于映射到表的列标题，因为不同情况下的标题不同。

我正在尝试实现这样的目标：

我发现了这一点，但实际上我只需要一个简单的插入操作。

如果下面的 Python 代码不存在该表，我将创建一个 cassandra 表：

当我设置 modelID = 12345 时，终端出现错误。

我的语法有什么问题？

我在 cassandra 上运行一些测试，需要在每次运行后删除表中的数据。所以我写了一个截断数据的脚本。我的问题是，在我截断表后，它是否使表未配置（删除所有列）？我是卡桑德拉初学者。需要对此有所了解。

我有一个用户定义的 python 库，它解析文件中的数据并返回键值对。现在如何使用这个库将数据插入 Cassandra 列族？我正在使用 python Cassandra 驱动程序。

我正在尝试找到一种方法来记录从 python 代码在 Cassandra 上完成的所有查询。使用 BatchStatement

是否有任何钩子或回调我可以用来记录这个？

我正在使用 python 驱动程序和 Cassandra，我创建了以下架构

我的问题是，如何使用followDateselect 和 update 查询的 in where 子句，我已经尝试过，但它不起作用它给出以下错误

任何人都可以帮助我吗？

这是我的代码 channelLike = channelSession.execute("update channelfollowers set isblocked=%s, isfavorite=%s where userid=%s and channelid=%s and followdate=%s",[int(userid),int(channel_id),followDate]

我有 2 个 cassandra 集群，我的简单脚本试图读取一个并写入另一个。根据此处的文档，我有一个registered_connection（命名）到第二个集群和一个到第一个集群的默认连接。我可以使用以下方法查询不同的集群：

但是，当我尝试使用以下方法将项目写入/保存到另一个集群时：

它不会引发错误，但也不会写入集群。我通过查询接收器集群验证了这一点。我是否遗漏了文档中明显的内容？

PS：在第一个场景中，它ModelQuerySet是应用自定义连接的对象，而在保存场景中，它是Model对象。

我正在使用 python cassandra 驱动程序，我已经搜索了如何获取最后插入的 id，但找不到除此之外的任何解决方案，但我想获取 uuid 或 id 而不是时间戳

任何人都可以帮助我吗？

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

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

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

我正在为我的项目使用 Scylla 数据库和 python Cassandra 驱动程序，我在每个查询上都使用了准备好的语句并且它可以工作，但是当我在物化视图上使用准备好的语句时，它什么也没有返回，你能帮我吗，有什么限制或别的东西？

这是我的架构

CREATE MATERIALIZED VIEW favoriteChannels AS SELECT channelid, userid, isfavorite FROM channels.channelfollowers WHERE channelid IS NOT NULL and userid IS NOT NULL and isfavorite IS NOT NULL PRIMARY KEY (isfavorite,userid,channelid,followDate);