Cassandra 创建多个连接而不释放

Question

我正在使用 Python Cassandra-Driver 3.15.1

我有一个运行多进程的脚本。

问题是由于某种原因，调用close_connection（get_connection->运行CQL->close_connection->然后到结束调用close_cluster后连接没有正确释放。这导致超过数百个连接/会话保持打开状态

非常感谢任何有关在何处查找问题的提示。

def get_connection(self, timeout = 600):
    self.session = Cluster([self.host]).connect()
    self.session.default_timeout = timeout
    return self.session

def close_connection(self, conn):
    return conn.shutdown()

def close_cluster_connection(self):
    return self.cluster.shutdown()

Answer 1

每个Cluster 对象在完成后都应该显式关闭，但这在此处是不可能的，因为您没有保留Cluster([self.host]) 在get_connection 中创建的实例。

close_cluster_connection 引用 self.cluster。如果它已经实例化并且您要使用的集群实例，get_connection 应该如下所示。

def get_connection(self, timeout = 600):
    self.session = self.cluster.connect()
    self.session.default_timeout = timeout
    return self.session

如果您不能在那里使用self.cluster，您必须找到一种方法来跟踪您的Cluster 实例并在完成后关闭它们。