我如何通过 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