2

每次我尝试使用 cassandra python 驱动程序获取查询时，都会收到这样的异常：

**File "something.py", line 32, in <module>
    rows = session.execute('some query execution', timeout=None)
  File "C:\Anaconda2\lib\site-packages\cassandra\cluster.py", line 2141, in execute
    return self.execute_async(query, parameters, trace, custom_payload, timeout, execution_profile, paging_state).result()
  File "C:\Anaconda2\lib\site-packages\cassandra\cluster.py", line 4033, in result
    raise self._final_exception
cassandra.ReadTimeout: Error from server: 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': 'LOCAL_ONE'}**

为避免此异常，我已经尝试将默认超时设置为无，例如：

cluster.default_timeout = None
session.default_timeout = None
session.execute('some query execution', timeout=None)

但是，它们从未真正更改 Readtimeout 期间。

需要注意的一点是，当我在 Squrriel 中执行此查询命令时，它不会花费太长时间，大约 1.5 秒。

有谁知道如何解决这个问题？谢谢！

4

1 回答 1

-1

这里的关键信息是Coordinator node timed out waiting for replica nodes' responses——这意味着超时发生在 Cassandra 本身内部。在您的情况下，请求不会直接发送到拥有数据的节点，而是发送到充当 的节点之一Coordinator，然后该节点将请求重新发送到拥有数据的节点，并且没有得到答复在分配的时间内从它。

我记不太清了，但是 Python 驱动程序应该使用所谓的TokenAware负载平衡策略，这将使驱动程序直接向拥有数据的节点发送请求——你需要检查你是否使用了这个策略。

此外，您需要检查 Cassandra 节点上的日志以找出它们超时的原因，并在必要时调整这些节点上的超时。

于 2018-06-01T07:08:26.087 回答