cassandra与uwsgi和django意外引发nohostavailable异常

r9f1avp5  于 2021-06-13  发布在  Cassandra
关注(0)|答案(0)|浏览(271)

我用Cassandra和uwsgi和django。这对我们来说几乎半年都很有效,但最近开始出现了一个例外。

Traceback (most recent call last):

  File "cassandra/cluster.py", line 2615, in cassandra.cluster.Session.execute

    return self.execute_async(query, parameters, trace, custom_payload, timeout, execution_profile, paging_state, host, execute_as).result()

  File "cassandra/cluster.py", line 4871, in cassandra.cluster.ResponseFuture.result

    raise self._final_exception

NoHostAvailable: ('Unable to complete the operation against any hosts', {<Host: 10.10.10.72:9042 dc1>: ConnectionException('Pool is shutdown',), <Host: 10.10.10.71:9042 dc1>: ConnectionException('Pool is shutdown',), <Host: 10.10.10.69:9042 dc1>: ConnectionException('Pool is shutdown',), <Host: 10.10.10.70:9042 dc1>: ConnectionException('Pool is shutdown',), <Host: 10.10.10.68:9042 dc1>: ConnectionException('Pool is shutdown',)})

这种异常是偶然发生的,有时django整天都工作得很好,有时在正常运行一小时后没有任何规律地出现异常。django工人在uwsgi重启后工作得很好,然后在一段时间后重复这个问题。
对我来说
python 2.7版
Cassandra驱动程序3.23
cassandra服务器3.11.5
我们有一个5节点的cassandra集群,从所有客户端连接大约6000个
写入和读取操作都处于低吞吐量水平
异常出现时,服务器端系统日志显示无任何错误消息,节点状态正常。
带有lazy函数的client init如下所示

cluster = Cluster(contact_points=['10.10.10.68','10.10.10.69'],

                  protocol_version=4,

                  port=9042,

                  load_balancing_policy=RoundRobinPolicy())

mydb = cluster.connect('mydb')

mydb.execute('select * from cass_tbl limit 1')

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题