概要描述

本文介绍如何使用 Python 连接和操作 Zookeeper。

详细说明

适用环境

操作系统： Windows/Linux/MacOS 均可

Python版本： Python 3.6+

TDH版本： 对全版本 TDH 下的 Zookeeper 均适用。

依赖安装

请在 Python 环境下通过 pip 安装以下依赖。

$ pip install kazoo

如果环境无法连接外网，请至 PYPI 官方网站下载 Kazoo 的 wheel 包手动安装。

代码示例

#coding: utf-8

'''
基于kazoo，官方文档：https://kazoo.readthedocs.io/en/latest/basic_usage.html
'''

from kazoo.client import KazooClient

#建立客户端连接

zk = KazooClient(hosts='172.22.39.7:2181,172.22.39.8:2181,172.22.39.9:2181')
zk.start()

#查看节点

print("********\nVIEW NODES\n********")
node = zk.get_children('/')
print(node)

#创建节点

print("********\nCREATE NODES\n********")
zk.create('/abcdef', b'this is test')
node = zk.get_children('/')
print(node)

#查看数据

print("********\nVIEW DATA\n********")
data = zk.get('/abcdef')
print(data)

#更新数据

print("********\nUPDATE DATA\n********")
zk.set('/abcdef', b'this is also test')
data = zk.get('/abcdef')
print(data)

#删除节点

print("********\nDELETE NODES\n********")
zk.delete('/abcdef', recursive=True)
node = zk.get_children('/')
print(node)

#关闭客户端连接

zk.stop()