python - 从 Cassandra Columnfamily 读取数据时出现奇怪的行为

Question

我正在尝试使用 cqlsh 对列族执行以下查询(cqlsh 5.0.1 | Cassandra 2.1.12 | CQL 规范 3.2.1 | native 协议(protocol) v3)

查询:

select * from CassandraColumnFamily limit 10

但它给出了以下错误

错误:

ReadTimeout: code=1200 [Coordinator node timed out waiting for replica nodes' responses] message="Operation timed out - received only 0 responses." info={'received_responses': 0, 'required_responses': 1, 'consistency': 'ONE'}

我可以使用以下 python 脚本读取数据。我无法弄清楚这里可能出现什么问题。

cluster = Cluster(
            contact_points = ['IP1','IP2','IP3']
            )
    session = cluster.connect('cw')       
    query = "select col1 , col2, col3, col4, col5 from CassandraColumnFamily"
    statement = SimpleStatement(query, fetch_size=50000)

Answer 1

我不确定您尝试获取的行有多大以及有多少行。但是，当您在没有主键任何条件的情况下在 CQL 中进行选择时，您正在执行范围扫描，这是昂贵的。请记住，这不是 MySQL。当您对特定行键进行查找时，Cassandra 的工作效果最佳。

无论如何，您可以尝试增加 cqlsh 的超时时间来实现此目的。

在您的主文件夹中，创建一个名为 cqlshrc 的文件，其中包含以下内容:[联系]client_timeout = 10

您还可以这样设置来禁用超时:client_timeout = 无

有关 cqlshrc 的更多信息 https://docs.datastax.com/en/cql/3.1/cql/cql_reference/cqlshrc.html