首先Cassandra是使用docker-swarm同微服務(wù)一同部署的。

問(wèn)題的關(guān)鍵在于尋找到Cassandra的9042端口，從而獲取數(shù)據(jù)。

問(wèn)題一：在主節(jié)點(diǎn)Ping Cassandra容器的IP，由于利用docker-swarm網(wǎng)橋連接的容器，兩者的IP不在同一網(wǎng)段，所以ping失敗，無(wú)法獲取9042端口。

問(wèn)題二：在Cassandra容器內(nèi)輸入ip addr，得到結(jié)果如下：

得到兩個(gè)IP字段，其中下面的IP字段對(duì)應(yīng)的是docker-swarm創(chuàng)建的網(wǎng)橋，在主節(jié)點(diǎn)嘗試ping一下，竟然可以ping通。但訪問(wèn)IP:9042訪問(wèn)被拒絕。

問(wèn)題三：進(jìn)入到同網(wǎng)段下的容器內(nèi)，ping兩個(gè)IP字段都可以ping通，而且可以訪問(wèn)9042端口。但是在容器內(nèi)操作較麻煩，我的目的是在節(jié)點(diǎn)中進(jìn)行操作。

解決辦法： 嘗試在Cassandra容器所在的節(jié)點(diǎn)ping兩者，雖然前者仍無(wú)法ping通，但后者可以ping通，進(jìn)入容器執(zhí)行

cqlsh 172.18.0.3 #網(wǎng)橋分配IP

發(fā)現(xiàn)可以進(jìn)入數(shù)據(jù)庫(kù)，應(yīng)該是網(wǎng)橋分配的IP是可以連接的，但是在節(jié)點(diǎn)上沒(méi)有打開(kāi)9042端口，所以導(dǎo)致訪問(wèn)被拒絕。打開(kāi)9042端口即可。由于時(shí)間問(wèn)題，我直接在容器節(jié)點(diǎn)上進(jìn)行測(cè)試。代碼如下：

#!/usr/bin/env python3
 
from cassandra.cluster import Cluster
from cassandra.query import tuple_factory
from cassandra.policies import DCAwareRoundRobinPolicy
from cassandra.policies import DowngradingConsistencyRetryPolicy
from cassandra import ConsistencyLevel
from cassandra.query import dict_factory
import sys
 
def conn():
 
	cluster = Cluster(["172.18.0.3"])
	session=cluster.connect('jaeger_v1_dc1')
	return session
 
if __name__ == '__main__':
 
	session = conn()
	data = session.execute("select duration from traces limit 10;")
	for i in data:
		print (i)
	session.shutdown()

到此這篇關(guān)于關(guān)于Python連接Cassandra容器進(jìn)行查詢(xún)的問(wèn)題的文章就介紹到這了,更多相關(guān)Python連接Cassandra內(nèi)容請(qǐng)搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！

版權(quán)聲明：本站文章來(lái)源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來(lái)源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來(lái)源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來(lái)，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。