關于Python連接Cassandra容器進行查詢的問題
首先Cassandra是使用docker-swarm同微服務一同部署的。
問題的關鍵在于尋找到Cassandra的9042端口,從而獲取數(shù)據(jù)。
問題一:在主節(jié)點Ping Cassandra容器的IP,由于利用docker-swarm網(wǎng)橋連接的容器,兩者的IP不在同一網(wǎng)段,所以ping失敗,無法獲取9042端口。

問題二:在 Cassandra容器內(nèi)輸入ip addr,得到結果如下:

得到兩個IP字段,其中下面的IP字段對應的是docker-swarm創(chuàng)建的網(wǎng)橋,在主節(jié)點嘗試ping一下,竟然可以ping通。但訪問IP:9042訪問被拒絕。
問題三:進入到同網(wǎng)段下的容器內(nèi),ping兩個IP字段都可以ping通,而且可以訪問9042端口。但是在容器內(nèi)操作較麻煩,我的目的是在節(jié)點中進行操作。
解決辦法: 嘗試在Cassandra容器所在的節(jié)點ping兩者,雖然前者仍無法ping通,但后者可以ping通,進入容器執(zhí)行
cqlsh 172.18.0.3 #網(wǎng)橋分配IP
發(fā)現(xiàn)可以進入數(shù)據(jù)庫,應該是網(wǎng)橋分配的IP是可以連接的,但是在節(jié)點上沒有打開9042端口,所以導致訪問被拒絕。打開9042端口即可。由于時間問題,我直接在容器節(jié)點上進行測試。代碼如下:
#!/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內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
python改變?nèi)罩?logging)存放位置的示例
示例主要解決的問題是通過傳入日志文件參數(shù)的方式來改變?nèi)罩镜拇娣盼恢?需要的朋友可以參考下2014-03-03
python計算Content-MD5并獲取文件的Content-MD5值方式
這篇文章主要介紹了python計算Content-MD5并獲取文件的Content-MD5值方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-04-04
Appium+python自動化之連接模擬器并啟動淘寶APP(超詳解)
這篇文章主要介紹了Appium+python自動化之 連接模擬器并啟動淘寶APP(超詳解)本文以淘寶app為例,通過實例代碼給大家介紹的非常詳細,需要的朋友可以參考下2019-06-06
tensorflow 用矩陣運算替換for循環(huán) 用tf.tile而不寫for的方法
今天小編就為大家分享一篇tensorflow 用矩陣運算替換for循環(huán) 用tf.tile而不寫for的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-07-07

