如何使用 DataStax Python Driver 连接 Cassandra？

推荐答案

// www.javascriptcn.com code example
from cassandra.cluster import Cluster

# 连接到 Cassandra 集群
cluster = Cluster(['127.0.0.1'])  # 替换为你的 Cassandra 节点 IP 地址
session = cluster.connect()

# 选择一个 keyspace
session.set_keyspace('your_keyspace')  # 替换为你的 keyspace 名称

# 执行 CQL 查询
rows = session.execute('SELECT * FROM your_table LIMIT 10')  # 替换为你的表名
for row in rows:
    print(row)

# 关闭连接
cluster.shutdown()

本题详细解读

1. 安装 DataStax Python Driver

首先，你需要安装 DataStax Python Driver。可以通过 pip 安装：

pip install cassandra-driver

2. 导入必要的模块

在代码中，首先需要导入 Cluster 类，这是 DataStax Python Driver 提供的用于连接 Cassandra 集群的核心类。

from cassandra.cluster import Cluster

3. 连接到 Cassandra 集群

使用 Cluster 类创建一个集群对象，并传入 Cassandra 节点的 IP 地址列表。你可以指定一个或多个节点地址。

cluster = Cluster(['127.0.0.1'])  # 替换为你的 Cassandra 节点 IP 地址

4. 创建会话

通过 cluster.connect() 方法创建一个会话对象。会话对象用于执行 CQL 查询。

session = cluster.connect()

5. 选择 keyspace

在 Cassandra 中，keyspace 类似于数据库。你可以使用 session.set_keyspace() 方法选择一个 keyspace。

session.set_keyspace('your_keyspace')  # 替换为你的 keyspace 名称

6. 执行 CQL 查询

使用 session.execute() 方法执行 CQL 查询。查询结果是一个可迭代的对象，你可以遍历它来获取每一行的数据。

rows = session.execute('SELECT * FROM your_table LIMIT 10')  # 替换为你的表名
for row in rows:
    print(row)

7. 关闭连接

最后，使用 cluster.shutdown() 方法关闭与 Cassandra 集群的连接，释放资源。

cluster.shutdown()

通过以上步骤，你可以成功使用 DataStax Python Driver 连接并操作 Cassandra 数据库。