python3 连接 zookeeper
时间:2019-11-18
本文章向大家介绍python3 连接 zookeeper,主要包括python3 连接 zookeeper使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
zookeeper的增 删 改 查 watch监听。
from kazoo.client import KazooClient import time,os import timeit os.chdir(os.getcwd()) def connection(): zk=KazooClient('localhost:2181') zk.start() #print(zk.connected) if zk.connected == "True": kk = "success" else: kk = "failed" print(zk.connected) return zk.connected def Utime(f): def timechange(*args,**kwargs): start_time=time.time() f(*args,**kwargs) end_time=time.time() execution_time=(end_time-start_time)*1000 return execution_time return timechange #增 @Utime def create(hosts,path,data): zk = KazooClient(hosts) zk.start() value=data.encode() zk.create(path,value,makepath=True) zk.stop() #删 @Utime def delete(hosts,path): zk1=KazooClient(hosts) zk1.start() zk1.delete(path) zk1.stop() #查 @Utime def get(hosts,path): zk2=KazooClient(hosts) zk2.start() zk2.get(path) zk2.stop() # return data #改 @Utime def set(hosts,path,data): zk3=KazooClient(hosts) zk3.start() value=data.encode() zk3.set(path,value) zk3.stop() #递归删 def delete_all(hosts,path): zk4=KazooClient(hosts) zk4.start(timeout=10) zk4.delete(path,recursive=True) zk4.stop() #watch def node_Watch(host,path): zk=KazooClient(host) zk.start() @zk.DataWatch(path) def my_change(data, stat): time.sleep(3) #print("Data is %s" % data) #print("Version is %s" % stat.version) #print("Event is %s" % event) while True: time.sleep(3) #print("OK")
原文地址:https://www.cnblogs.com/cyanrose/p/11882963.html
- Eclipse中Maven打包程序并在Linux中运行
- SDN开发笔记(七):L2switch源码分析(上)
- spark使用zipWithIndex和zipWithUniqueId为rdd中每条数据添加索引数据
- Spring Boot Server容器配置
- Spring Boot读取配置的几种方式
- 如何用TensorFlow构建RNN?这里有一份极简的教程
- (1024程序员节快乐)阿里祭出大器,Java代码检查插件
- Java多线程神器:join使用及原理
- SpringCloud配置中心内容加密
- Spring Boot日志集成
- MongoDB系列7:MongoDB存储引擎
- MongoDB系列6:MongoDB索引的介绍
- 文本数据处理的终极指南-[NLP入门]
- 神经网络思想建立LR模型(DL公开课第二周答案)
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Day14:链表中倒数第k个结点
- Flutter开发笔记——BottomNavigationBar设置未选择Item颜色
- 访问虚拟机局域网服务拒绝连接
- uninstalling vim-minimal 同时也卸载了 sudo 解决方法
- 大点干!早点散----------深入剖析缓存加速--squid(反向代理与ACL访问控制以及sarg日志)
- JVM的Xms和Xmx参数设置为相同值有什么好处?
- 【CVPR 2020】一种新的门控通道注意力转换单元
- 5个好用的 CSS 函数
- java1.8中Object类源码分析
- 多线程基础(六):Object的wait方法以及notify与notifyAll的区别
- Day15:反转链表
- Day16:合并两个排序的链表
- 大厂面试爱问的「调度算法」,20 张图一举拿下
- Day17:树的子结构
- 多线程基础(七):关于HotSpot中notify方法不具备随机性的证明