python系列之：kazoo连接Zookeeper操作Zookeeper

一、连接zookeeper

from kazoo.client import KazooClient
zk = KazooClient(hosts="10.128.242.107")
zk.start()

二、读取zookeeper节点

rootPath = "/data"
firstChildrenList = zk.get_children(rootPath)
print(firstChildrenList)

三、读取zookeeper内容

nodePath = "/data/flume"
content = zk.get(nodePath)

四、kazoo连接Zookeeper操作Zookeeper完整代码

from kazoo.client import KazooClient
zk = KazooClient(hosts="10.128.242.107")
zk.start()
rootPath = "/data/"
firstChildrenList = zk.get_children(rootPath)
print(firstChildrenList)

nodePath = "/data/flume"
data = zk.get(nodePath)
print(data)

输出如下所示：
(b’c3ff641ecfc1f9d9e30c761e3bab215d25db0df0242f9285f9e5b2e2876d494036b3b135f599bb7a8e6817d9433385ab’, ZnodeStat(czxid=4294982871, mzxid=17179917989, ctime=1577421208843, mtime=1647335121232, version=9, cversion=0, aversion=0, ephemeralOwner=0, dataLength=96, numChildren=0, pzxid=4294982871))