如何从指定Cassandra节点查询且仅获取该节点本地数据？

当然可行！要实现这个需求，你需要结合驱动连接配置和查询语句的特殊设置，从两个层面阻止节点转发查询请求：

1. 第一步：强制驱动仅与目标节点通信 #

首先，你需要确保Python驱动只连接到指定的目标节点，不会和集群内其他节点建立连接。可以通过WhiteListRoundRobinPolicy实现这一点：

from cassandra.cluster import Cluster
from cassandra.policies import WhiteListRoundRobinPolicy

# 替换成目标节点的IP地址
target_node_ip = "192.168.1.100"
# 白名单策略只允许连接指定节点
policy = WhiteListRoundRobinPolicy([target_node_ip])
cluster = Cluster(contact_points=[target_node_ip], load_balancing_policy=policy)
session = cluster.connect()

这个配置会让驱动的连接池只维护与目标节点的连接，不会尝试连接其他节点，但这只是第一步；要阻止节点本身转发查询，还需要做下面的设置。

2. 第二步：查询时限定Token范围+强制本地执行 #

接下来，你需要在查询中明确指定目标Token范围，同时通过一致性级别和执行参数，让目标节点只查询本地存储的数据，不转发请求：

2.1 先获取目标节点负责的Token范围（可选但建议） #

你可以用nodetool ring命令查看集群的Token分布，或者通过驱动获取目标节点的Token信息：

# 获取目标节点的Token范围
target_node = cluster.metadata.all_hosts()[0]
# 节点负责的Token范围（Cassandra的Token是有序的，通常为连续区间）
token_start = target_node.tokens[0]
token_end = target_node.tokens[-1]

2.2 编写带Token范围的CQL查询，并设置强制本地执行 #

在执行查询时，需要做到三点：

• 用token()函数限定查询的分区键在目标Token范围内
• 设置一致性级别为LOCAL_ONE（确保只从本地节点获取数据）
• 强制在目标节点执行查询（通过host参数指定）

示例代码：

from cassandra.query import SimpleStatement
from cassandra import ConsistencyLevel

# 替换成你的表名和分区键字段名
table_name = "your_table"
pk_column = "your_partition_key"

# 构造查询语句：限定Token范围
query = f"""
SELECT * FROM {table_name}
WHERE token({pk_column}) >= %s AND token({pk_column}) <= %s
"""
# 创建语句对象，设置一致性级别为LOCAL_ONE
statement = SimpleStatement(query, consistency_level=ConsistencyLevel.LOCAL_ONE)

# 执行查询时，强制指定在目标节点执行，传入Token范围参数
result = session.execute(statement, (token_start, token_end), host=target_node)

关键原理说明 #

• WhiteListRoundRobinPolicy确保驱动只和目标节点通信，不会自动切换到其他节点；
• LOCAL_ONE一致性级别告诉Cassandra，只需要从本地数据中心的当前节点获取数据，不需要去其他节点查询；
• 用token()限定分区键范围后，目标节点只会扫描自己本地存储的该范围内的数据，不会因为部分数据不在本地就转发请求到其他节点——完全符合你“只查当前节点本地数据”的需求。

注意事项 #

• 如果你的Token范围跨了多个节点，目标节点只会返回自己本地存储的那部分数据，不会拉取其他节点的数据；
• 确保你使用的Cassandra Python驱动版本支持host参数（主流新版本都支持）；
• 如果表有多个副本，LOCAL_ONE只会返回目标节点上的副本数据，不会去其他副本节点查询。

内容的提问来源于stack exchange，提问作者user17963