python - 如何使用 Cassandra Python 驱动程序设置/覆盖客户端请求超时？

Question

我有一个简单的脚本来将新记录插入 Cassandra 数据库。它在我的本地计算机上运行良好，但当我将数据库移动到远程计算机时，我收到来自客户端的超时错误。如何正确设置该驱动程序的超时？我已经尝试了很多事情。我破解了 IDE 中的超时并让它在没有超时的情况下工作，所以我确信这只是一个超时问题。

如何设置我的集群:

profile = ExecutionProfile(request_timeout=100000)
self.cluster = Cluster([os.getenv('CASSANDRA_NODES', None)], auth_provider=auth_provider,
                       execution_profiles={EXEC_PROFILE_DEFAULT: profile})
connection.setup(hosts=[os.getenv('CASSANDRA_SEED', None)],
                 default_keyspace=os.getenv('KEYSPACE', None),
                 consistency=int(os.getenv('CASSANDRA_SESSION_CONSISTENCY', 1)), auth_provider=auth_provider,
                 connect_timeout=200)

session = self.cluster.connect()

我尝试执行的查询:

model = Model.create(buffer=_buffer, lock=False, version=self.version)

13..': 'Client request timeout. See Session.execute_async'}, last_host=54.213..

我插入的记录是 11mb，所以我可以理解存在延迟，只需增加超时就可以了，但我似乎无法弄清楚。

Answer 1

默认请求超时是 Session 对象(驱动程序版本 2.0.0 及更高版本)的一个属性。

session = cluster.connect(keyspace)
session.default_timeout = 60

这是最简单的答案(无需搞乱执行配置文件)，并且我已经确认它有效。

https://datastax.github.io/python-driver/api/cassandra/cluster.html#cassandra.cluster.Session