一、连接zookeeper二、读取zookeeper节点三、读取zookeeper内容四、kazoo连接Zookeeper操作Zookeeper完整代码
一、连接zookeeperfrom 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))



