Kazoo安装和使用

kazoo是Python连接操作ZooKeeper的客户端库。我们可以通过kazoo来使用ZooKeeper。

1. 安装

pip install kazoo

2. 使用

连接ZooKeeper

from kazoo.client import KazooClientzk = KazooClient(hosts='127.0.0.1:2181')# 启动连接
zk.start() # 停止连接
zk.stop()

创建节点

# 创建节点路径，但不能设置节点数据值
zk.ensure_path("/my/favorite")# 创建节点，并设置节点保存数据，ephemeral表示是否是临时节点，sequence表示是否是顺序节点
zk.create("/my/favorite/node", b"a value", ephemeral=True, sequence=True)

读取节点

# 获取子节点列表
children = zk.get_children("/my/favorite")# 获取节点数据data 和节点状态stat
data, stat = zk.get("/my/favorite")

设置监视

def my_func(event):# 检查最新的节点数据# 当子节点发生变化的时候，调用my_func
children = zk.get_children("/my/favorite/node", watch=my_func)

Kazoo安装和使用相关推荐

zookeeper教程,docker 安装,命令,python操作zookeeper，分布式队列，分布式锁
docker安装zookeeper服务端首先安装单节点的服务端,如果安装多节点的服务端,需要为每个节点配置其他节点的地址. docker run --privileged=true -d --nam ...
python zookeeper api_Zookeeper接口kazoo实例解析
本文主要研究的是Zookeeper接口kazoo的相关内容,具体介绍如下. zookeeper的开发接口以前主要以java和c为主,随着python项目越来越多的使用zookeeper作为分布式集群实 ...
如何在CDH5.16.2中部署海豚调度器Apache Dolphin Scheduler 1.2.0
Apache Dolphin Scheduler 组件介绍分布式易扩展的可视化DAG工作流任务调度系统.致力于解决数据处理流程中错综复杂的依赖关系,使调度系统在数据处理流程中开箱即用. 官网 : h ...
JAVA软件海豚_海豚调度系统Apache DolphinScheduler单机部署官方文档(Standalone)
DolphinScheduler单机部署分为后端部署和前端部署两部分: 1.后端部署 1.1 : 基础软件安装(必装项请自行安装) PostgreSQL (8.2.15+) or MySQL (5.7 ...
python zookeeper_ZooKeeper的安装以及客户端Kazoo（Python语言）的安装与使用
ZooKeeper具体的安装流程,如下所示: 首先,由于ZooKeeper是JAVA开发的,所以先要安装JDK,此处我是安装在/usr/local/jdk目录下,设置环境变量即可. 第二,到ZooKe ...
原创：centos7.1下 ZooKeeper 集群安装配置+Python实战范例
centos7.1下 ZooKeeper 集群安装配置+Python实战范例下载:http://apache.fayea.com/zookeeper/zookeeper-3.4.9/zookeepe ...
Python：kazoo模块与Zookeeper交互
github: https://github.com/python-zk/kazoo 文档: https://kazoo.readthedocs.io/en/latest/ 安装 $ pip inst ...
Python——ZooKeeper库Kazoo入门
文章目录 1. 简介 2. 安装 2.1 JRE 2.2 ZooKeeper 2.3 ZooInspector 2.4 Kazoo 3. 建立连接 4. 增删改查 4.1 创建节点 4.2 读 4.3 ...
Kazoo Python Zookeeper 选主
本文讲述基于zookeeper选主与故障切换的方法.我们的例子使用的是python. 使用的库是kazoo,安装方式 pip install kazoo 应用场景: 多个实例部署,但不是"去 ...

Kazoo安装和使用

1. 安装

2. 使用

Kazoo安装和使用相关推荐

最新文章

热门文章