使用Cassandra Python-Driver执行SELECT查询时遭遇ReadFailure错误求助

首先得说，单节点Cassandra出现ReadFailure确实有点反常，毕竟没有多节点的一致性同步问题，咱们一步步来排查解决：

1. 先确认节点状态与复制因子配置 #

检查Cassandra节点是否正常运行 #

你是用tar包启动的，先看看节点进程是否存活，或者查看Cassandra的日志（默认在{安装目录}/logs/system.log），有没有报错信息，比如内存不足、磁盘IO异常这类问题。

验证Keyspace的复制因子 #

如果你的Documents keyspace复制因子设置成了大于1（比如默认的3），那单节点根本满足不了一致性级别要求，必然会报错。可以用cqlsh执行命令查看：

DESCRIBE KEYSPACE Documents;

如果复制因子不是1，赶紧修改：

ALTER KEYSPACE Documents WITH REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1};

2. 调整查询的一致性级别 #

python-driver默认的一致性级别可能是QUORUM，虽然单节点+复制因子1的情况下QUORUM等于1，但有时候驱动的判断可能有延迟，直接指定ONE级别更稳妥。在查询时显式设置：

from cassandra.cluster import Cluster, ConsistencyLevel
from cassandra.query import SimpleStatement

cluster = Cluster(['127.0.0.1'])
session = cluster.connect('Documents')

query = SimpleStatement("SELECT name, object FROM your_table_name", consistency_level=ConsistencyLevel.ONE)
results = session.execute(query)

3. 排查数据与查询负载问题 #

检查Blob字段大小 #

你用pickle存Python实例，如果某些实例序列化后体积过大（比如超过Cassandra默认的单个列大小限制，虽然默认是1GB，但过大的数据会导致读取超时），可以先尝试查询小范围数据，比如加个LIMIT测试：

query = SimpleStatement("SELECT name, object FROM your_table_name LIMIT 10", consistency_level=ConsistencyLevel.ONE)
results = session.execute(query)

如果小范围查询正常，那就是大量数据一次性读取导致的节点负载过高，这时候要启用分页查询：

# 驱动默认分页大小是500，可以根据实际情况调整
query = SimpleStatement("SELECT name, object FROM your_table_name", consistency_level=ConsistencyLevel.ONE, fetch_size=100)
results = session.execute(query)
for row in results:
    # 处理每一行数据，比如反序列化object
    unpickled_obj = pickle.loads(row.object)
    pass

检查驱动与Cassandra版本兼容性 #

确保你的python-driver版本和Cassandra版本匹配，比如Cassandra 4.x对应python-driver 3.25+，如果版本不兼容也可能出现奇怪的错误。可以用pip show cassandra-driver查看版本，然后调整到匹配的版本。

4. 检查Cassandra的JVM配置 #

tar包安装的Cassandra默认JVM堆内存可能不够，比如如果你的数据量较大，堆内存不足会导致节点处理查询时崩溃。可以修改{安装目录}/conf/jvm.options里的-Xms和-Xmx参数，比如调整为：

-Xms4G
-Xmx4G

修改后重启Cassandra节点。

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