python cassandra驅動程序：嘗試重新連接時出錯

Question

我使用python-cassandra驅動程序，而cassandra集羣位於AWS。 遠程連接時有很多警告。有沒有人有同樣的問題？

從cassandra.cluster導入cassandra 導入集羣 ... 在[3]：cassandra。 版本 缺貨[3]： '2.5.1'

警告：cassandra.pool：錯誤嘗試重新連接到172.31.24.108，調度重試在128.0秒：超時連接到172.31.24.108

Answer 1

我認爲這是因爲你無法直接連接到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)