多节点cassandra集群 - 负载平衡_policy

1 人关注
我在从我的Python连接器连接我的cassandra时遇到了一些问题
Connotor.py包含以下代码
from cassandra.cluster import Cluster
from cassandra.auth import PlainTextAuthProvider
from cassandra import ReadTimeout
import os
class CassandraConnection():
    def getConnection():
        auth_provider = PlainTextAuthProvider(username ='admin', password='Dog2019')
        cluster=Cluster(['a5ad8e558c23e9a524-1196365.us-west-2.elb.amazonaws.com'], auth_provider=auth_provider)
        session = cluster.connect()
        session.set_keyspace('tonnage')
        cluster.connect()
        return session
While run my python code getting this error
  cassandra.cluster:Cluster。init被调用，并指定了 contact_points
  的情况下调用，但没有指定load_balancing_policy。在下一个主要版本中。
  这将引发一个错误；请指定一个负载平衡策略。
  (contact_points =
  ['a5ad8e558c23e9a524-1196365.us-west-2.elb.amazonaws.com'], lbp =
  
cassandra.pool:试图重新连接到100.100.0.3时出错。
  调度重试时间为4.0秒。[Errno None] 尝试连接到
  [('100.100.0.3', 9042)].最后一个错误：超时了
  cassandra.pool:尝试重新连接到100.100.0.2时出错。
  在128.0秒内安排重试。[Errno None] 尝试连接到
  [('100.100.0.2', 9042)].最后一个错误：超时了
  cassandra.pool:尝试重新连接到100.100.0.2时出错。
  调度重试时间为4.0秒。[Errno None] 尝试连接到
  [('100.100.0.2', 9042)].最后一个错误：超时了
INFO:cassandra.policy:为DCAwareRoundRobinPolicy使用数据中心'datacenter1'（通过主机'34.217.153.0'）；如果不正确，请向构造器指定一个local_dc，或将接触点限制在本地集群节点上。
INFO:cassandra.cluster:发现新的Cassandra主机
INFO:cassandra.cluster:发现新的Cassandra主机