關於Python連接Cassandra容器進行查詢的問題

Posted on by

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

問題的關鍵在於尋找到Cassandra的9042端口，從而獲取數據。

問題一：在主節點Ping Cassandra容器的IP，由於利用docker-swarm網橋連接的容器，兩者的IP不在同一網段，所以ping失敗，無法獲取9042端口。

問題二：在 Cassandra容器內輸入ip addr，得到結果如下：

 得到兩個IP字段，其中下面的IP字段對應的是docker-swarm創建的網橋，在主節點嘗試ping一下，竟然可以ping通。但訪問IP:9042訪問被拒絕。

問題三：進入到同網段下的容器內，ping兩個IP字段都可以ping通，而且可以訪問9042端口。但是在容器內操作較麻煩，我的目的是在節點中進行操作。

解決辦法： 嘗試在Cassandra容器所在的節點ping兩者，雖然前者仍無法ping通，但後者可以ping通，進入容器執行

cqlsh 172.18.0.3 #網橋分配IP

發現可以進入數據庫，應該是網橋分配的IP是可以連接的，但是在節點上沒有打開9042端口，所以導致訪問被拒絕。打開9042端口即可。由於時間問題，我直接在容器節點上進行測試。代碼如下：

#!/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()

到此這篇關於關於Python連接Cassandra容器進行查詢的問題的文章就介紹到這瞭,更多相關Python連接Cassandra內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：