我有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
请帮助。
你有什么种子?你用什么传闻?你可以在你的cassandra.yaml文件中找到答案。如果它是PropertyFileSnitch,是否可以包含cassandra-topology.properties的内容? – DineMartine
节点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 –