2015-10-20 81 views
0

我有2 dc和3节点:
DC1:cas01.dc01.net(172.16.3.15)和cas02.dc01.net(172.16.3.16)
DC2:cas01.dc02。例如净(172.16.9.3)。Python的无效列表节点卡桑德拉集群

运行下面的脚本:

cluster = Cluster(['cas01.dc01.net', 'cas02.dc01.net', 'cas01.dc02.net'],auth_provider=auth,protocol_version=3, load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='DC1')) 
session = cluster.connect('test') 

print '_dc_live_hosts:' 
for k, v in cluster.load_balancing_policy._dc_live_hosts.items(): 
    print "DC name: %s; Node address: %s" % (k, [node.address for node in v]) 

print 'Cluster metadata:' 
for host in cluster.metadata.all_hosts(): 
    print 'Datacenter: %s; Host: %s; Rack: %s' % (host.datacenter, host.address, host.rack) 

和接收响应:

_dc_live_hosts: 
DC name: DC1; Node address: ['cas01.dc01.net', 'cas01.dc02.net', 'cas02.dc01.net', '172.16.3.15'] 
DC name: DC2; Node address: ['172.16.9.3'] 
Cluster metadata: 
Datacenter: None; Host: cas01.dc01.net; Rack: None 
Datacenter: None; Host: cas01.dc02.net; Rack: None 
Datacenter: DC1; Host: 172.16.3.15; Rack: Rack1 
Datacenter: DC2; Host: 172.16.9.3; Rack: Rack1 
Datacenter: DC1; Host: cas02.dc01.net; Rack: Rack1 

为什么重复的节点?
如果指定IP地址的列表:节点

cluster = Cluster(['172.16.3.15', '172.16.3.16', '172.16.9.3'],auth_provider=auth,protocol_version=3, load_balancing_policy=DCAwareRoundRobinPolicy(local_dc='DC1')) 
... 

列表是正确的:

_dc_live_hosts: 
DC name: DС1; Node address: ['172.16.3.16', '172.16.3.15'] 
DC name: DС2; Node address: ['172.16.9.3'] 
Cluster metadata: 
Datacenter: DС1; Host: 172.16.3.16; Rack: Rack1 
Datacenter: DС1; Host: 172.16.3.15; Rack: Rack1 
Datacenter: DС2; Host: 172.16.9.3; Rack: Rack1 

请帮助。

+0

你有什么种子?你用什么传闻?你可以在你的cassandra.yaml文件中找到答案。如果它是PropertyFileSnitch,是否可以包含cassandra-topology.properties的内容? – DineMartine

+0

节点cas01.dc01.net: - 种子:“cas01.dc01.net,cas02.dc01.net”节点cas02.dc01.net: - 种子:“cas01.dc01.net,cas01.dc02.net”节点cas01。 dc02.net: - 种子:“cas01.dc02.net,cas01.dc01.net”endpoint_snitch:PropertyFileSnitch 拓扑:cas01.dc01.net = DC1:Rack1 cas02.dc01.net = DC1:Rack1 cas01.dc02。 net = DC2:Rack1 –

回答

0

我不知道这是唯一的问题,但:

  • 所有节点都必须具有相同的种子
  • 种子名单必须在每个数据中心的至少一个节点

试试这个:

- seeds : "172.16.3.16, 172.16.9.3" 
+0

它的bug python驱动https://datastax-oss.atlassian.net/browse/PYTHON-10 –

0

驱动程序如何工作的简短说明将阐明您的q题目了:

  1. 了在给Cluster构造通过节点列表是初始接触节点

    驾驶员选择的这些以创建控制连接的一个。如果其中一个节点不能立即访问,那么传递多个节点是一个很好的做法,因此驱动程序可以尝试不同的连接。

  2. 使用在步骤1中建立的控制连接,驱动程序从system表中检索有关集群拓扑的信息。它使用这些详细信息来填充群集元数据对象。

    system表(特别是peers表)的信息反映每个节点的配置(基于broadcast_addressrpc_address等)