多节点cassandra群集-load_balancing_policy

Question

您好，我无法通过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

运行我的python代码时遇到此错误

警告：

cassandra.cluster：Cluster。i​​nit用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.policies：将数据中心“ datacenter1”用于DCAwareRoundRobinPolicy（通过主机“ 34.217.153.0”）；如果不正确，请为构造函数指定一个local_dc，或将接触点限制为本地集群节点INFO：cassandra.cluster：发现了新的Cassandra主机INFO：cassandra.cluster：发现了新的Cassandra主机INFO：cassandra.cluster：Cassandra主机52.26.34.69已删除

Answer 1