python - 我如何通过 CQL 直接连接到 Cassandra 的示例（1）

Question

我需要完整的示例来向我展示如何通过 CQL 连接到 Cassandra。我正在开发一个应该用 (python) Django 编写的项目，我想直接做一些事情，而不仅仅是使用 cqlEngine 作为我的项目驱动程序。谢谢你的帮助。

Answer 1

这就是我让 python 与 cassandra 通信的方式。

首先，你需要建立一个连接，添加：

import cql
con= cql.connect(host="127.0.0.1",port=9160,keyspace="testKS")

然后生成一个用于查询的游标：

cur=con.cursor()
result=cur.execute("select * from TestCF")

我可以通过以下方式查看结果：

result.fetchone()

或者

result.fetch()

这个查询很好，不需要额外的库，比如 pycasaa 或 cqlengine