我使用 python-cassandra 驱动程序,cassandra 集群位于 AWS。
远程连接时有很多警告。有没有人有同样的问题?

进口 Cassandra
从 cassandra.cluster 导入集群
...
在[3]: Cassandra 。 版本
输出 [3]:'2.5.1'

警告:cassandra.pool:尝试重新连接到 172.31.24.108 时出错,在 128.0 秒内安排重试:连接到 172.31.24.108 超时

最佳答案

我认为这是因为您无法直接连接到 172.31.24.108(专用网络?)。在我的情况下,我只能连接到部分集群节点。
所以我所做的是遵循 HostFilterPolicy 的文档并创建我自己的过滤器。

    from cassandra.policies import HostFilterPolicy, RoundRobinPolicy

    CONN_HOSTS = ['172.235.33.32', '172.235.32.155']

    whitelist_filter_policy = HostFilterPolicy(
        child_policy=RoundRobinPolicy(),
        predicate=lambda host: host.address in CONN_HOSTS)
    # ...

    cluster = Cluster(
        contact_points=CONN_HOSTS,
        load_balancing_policy=whitelist_filter_policy,
        cql_version="3.2.1",
        protocol_version=3,
        ssl_options=ssl_options,
        port=9042,
        auth_provider=auth_provider)

关于cassandra - python cassandra 驱动程序 : Error attempting to reconnect,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/30602135/

10-16 23:00