使用Kazoo去增删改查zookeeper
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用Kazoo去增删改查zookeeper相关的知识,希望对你有一定的参考价值。
每一次新版本开发,都会有开发频繁的要求查看以前版本里zookeeper的内部配置,由于我公司规定zookeeper的密钥是不能轻易给开发人员的,所以每次开发找过来运维就要停下手里工作去帮忙看一下,这样一来二去就搞得运维很烦。于是就萌生一个念头,通过一个工具去查询zookeeper的节点情况,然后再将这个工具嵌入到django里做成web界面,让开发苦逼直接去django里查。
由于django是python语言写的,为了代码统一不至于看疯一个人,所以这个工具也要选择python系,那么就要使用Kazoo,因为它比较专业而且成熟。这里实验使用的python版本是2.7.5。
安装Kazoo的方法很简单,#pip install kazoo。然后启动zookeeper的服务端,安装zookeeper的方法去看:http://blog.51cto.com/chenx1242/1889715 。
基本操作如下:
from kazoo.client import KazooClient zk = KazooClient(hosts='Zookeeper的地址:2181') #如果是本地那就写127.0.0.1 zk.start() #与zookeeper连接 zk.stop() #与zookeeper断开
如果出现了“kazoo.handlers.threading.KazooTimeoutError: Connection time-out”这个错误,请检查zookeeper的进程是否已经启动。这里补充一句,zk.start()是以同步的形式连接服务集群。
如果要建立一个叫/abc/JQK/XYZ/0001的node,node里面的value是"this is my house" ,语句如下:
zk.create('/abc/JQK/XYZ/0001',b'this is my house',makepath=True) #makepath=True是递归创建,如果不加上中间那一段,就是建立一个空的节点 zk.ensure_path('/abc/JQK/XYZ/0001') #这样写是创建空的node
效果如图:
如果要删除这个/abc/JQK/XYZ/0001的子node,但是想要上一级XYZ这个node还是存在的,语句如下:
zk.delete('/abc/JQK/XYZ/0001',recursive=True) #recursive=True是递归删除,就是无视下面的节点是否是空,都干掉,不加上的话,会提示子节点非空,删除失败
现在假如要在0001这个node里更改value,比如改成:“this is my horse!”,语句如下:
>>> zk.set('/abc/JQK/XYZ/0001',"this is my horse!") ZnodeStat(czxid=80, mzxid=84, ctime=1513913337850, mtime=1513913601610, version=3, cversion=0, aversion=0, ephemeralOwner=0, dataLength=17, numChildren=0, pzxid=80)
注意!set这种增加节点内容的方式是覆盖式增加,并不是在原有基础上增添。而且添加中文的话可能在ZooInspecter里出现的是乱码,现在我们来到ZooInspecter看一下效果:
我现在在'/ps/spider/dlb-receiver/'下建立两个node,一个叫0001,另一个叫0002,现在若要查看“/ps/spider/dlb-receiver/“下面有多少个子节点,语句是:
>>> zk.get_children('/ps/spider/dlb-receiver') [u'0001', u'0002'] #可见目前只有两个子节点 >>> children = zk.get_children("/ps/spider/dlb-receiver") >>> print("There are %s children with names %s" % (len(children), children)) There are 2 children with names [u'0001', u'0002']
假设“/ps/spider/dlb-receiver/0001”它里面的value如图:
要查看这个“/ps/spider/dlb-receiver/0001”的value,语句是:
>>> zk.get('/ps/spider/dlb-receiver/0001') #获得的type是tuple(元组) ('-- this is mysql\r\nmysql = {\r\n\thost = "rm-bp116dn17141tx72j.mysql.rds.aliyuncs.com",\r\n\tport = 3306,\r\n\tdatabase = "lcyy123ht",\r\n\tusername = "lcyyoalalht",\r\n\tpassword = "dvlSdJyuw2ad43fg09",\r\n}\r\n\r\n-- this is redis\r\nredis = {\r\n\thost = "127.0.0.1",\r\n\tport = 6379,\r\n}', ZnodeStat(czxid=47, mzxid=110, ctime=1513863785337, mtime=1513924538981, version=6, cversion=0, aversion=0, ephemeralOwner=0, dataLength=255, numChildren=0, pzxid=47)) >>> print(zk.get('/ps/spider/dlb-receiver/0001')) #前面加上print也是可以的 ('-- this is mysql\r\nmysql = {\r\n\thost = "rm-bp116dn17141tx72j.mysql.rds.aliyuncs.com",\r\n\tport = 3306,\r\n\tdatabase = "lcyy123ht",\r\n\tusername = "lcyyoalalht",\r\n\tpassword = "dvlSdJyuw2ad43fg09",\r\n}\r\n\r\n-- this is redis\r\nredis = {\r\n\thost = "127.0.0.1",\r\n\tport = 6379,\r\n}', ZnodeStat(czxid=47, mzxid=110, ctime=1513863785337, mtime=1513924538981, version=6, cversion=0, aversion=0, ephemeralOwner=0, dataLength=255, numChildren=0, pzxid=47))
上面这一大坨tuple看起来很头疼,那么就精简一下:
>>> print(zk.get('/ps/spider/dlb-receiver/0001')[0]) #后面添加一个[0]即可 -- this is mysql mysql = { host = "rm-bp116dn17141tx72j.mysql.rds.aliyuncs.com", port = 3306, database = "lcyy123ht", username = "lcyyoalalht", password = "dvlSdJyuw2ad43fg09", } -- this is redis redis = { host = "127.0.0.1", port = 6379, } >>> print(zk.get('/ps/spider/dlb-receiver/0001')[1]) #这里是stat ZnodeStat(czxid=47, mzxid=118, ctime=1513863785337, mtime=1513926132280, version=8, cversion=2, aversion=0, ephemeralOwner=0, dataLength=261, numChildren=0, pzxid=120)
参考文章:http://izualzhy.cn/c/cpp/2016/10/05/zookeeper-python-kazoo-introduction
以上是关于使用Kazoo去增删改查zookeeper的主要内容,如果未能解决你的问题,请参考以下文章