cd zookeeper-3.4./src/c

./configure

make

make install

cd zookeeper-3.4./conf

mv zoo_sample.cfg zoo.cfg

vim zoo.cfg #修改dataDir=/data/database/zookeeper

mkdir -p /data/database/zookeeper

cd ..

zookeeper-3.4.-cdh5.0.0]# cd bin/

./zkServer.sh start  #启动服务

./zkServer.sh status #查看启动状态

>>> import zookeeper

>>> zk=zookeeper.init("localhost:2181")  #初始化zookeeper连接

#创建zookeeper节点

>>> zookeeper.create(zk,"/zk_for_py","mydata1",[{"perms":,"scheme":"world","id":"anyone"}],)

'/zk_for_py'

#获取'/'下面的所以节点

>>> zookeeper.get_children(zk,"/",None)

['app', 'zookeeper', 'zk_for_py']

#创建zookepper节点

>>> zookeeper.create(zk,"/zk_for_py1","mydata1",[{"perms":0x1f,"scheme":"world","id":"anyone"}],)

'/zk_for_py1'

#获取节点信息

>>> zookeeper.get(zk,"/zk_for_py1")

('mydata1', {'pzxid': 9L, 'ctime': 1398512377068L, 'aversion': , 'mzxid': 9L, 'numChildren': , 'ephemeralOwner': 0L, 'version': , 'dataLength': , 'mtime': 1398512377068L, 'cversion': , 'czxid': 9L})

>>> zookeeper.get_children(zk,"/zk_for_py1",None)

[]

>>> zookeeper.get_children(zk,"/")

['app', 'zookeeper', 'zk_for_py1', 'zk_for_py']
#节点的数据只能是字符串

>>> zookeeper.set(zk,"/zk_for_py1",{"k":"v"})

Traceback (most recent call last):

  File "<stdin>", line , in <module>

TypeError: must be string or read-only buffer, not dict

>>> zookeeper.set(zk,"/zk_for_py1","hello")  

>>> zookeeper.get(zk,"/zk_for_py1")

('hello', {'pzxid': 9L, 'ctime': 1398512377068L, 'aversion': , 'mzxid': 10L, 'numChildren': , 'ephemeralOwner': 0L, 'version': , 'dataLength': , 'mtime': 1398512533595L, 'cversion': , 'czxid': 9L})

>>> zookeeper.delete(zk,"zk_for_py")

Traceback (most recent call last):

  File "<stdin>", line , in <module>

zookeeper.BadArgumentsException: bad arguments

>>> zookeeper.delete(zk,"/zk_for_py")

>>> zookeeper.get(zk,"/zk_for_py1")

('hello', {'pzxid': 9L, 'ctime': 1398512377068L, 'aversion': , 'mzxid': 10L, 'numChildren': , 'ephemeralOwner': 0L, 'version': , 'dataLength': , 'mtime': 1398512533595L, 'cversion': , 'czxid': 9L})

>>> import zookeeper

>>> zk=zookeeper.init("localhost:2181")

>>> zookeeper.get(zk,"/zk_for_py1")

('hello', {'pzxid': 9L, 'ctime': 1398512377068L, 'aversion': , 'mzxid': 10L, 'numChildren': , 'ephemeralOwner': 0L, 'version': , 'dataLength': , 'mtime': 1398512533595L, 'cversion': , 'czxid': 9L})

#定义一个监听器

>>> def myWatch(zk,type,state,path):

...     print "zk:",str(type),str(state),str(path)

...     zookeeper.get(zk,path,myWatch)

...

>>> data=zookeeper.get(zk,"/zk_for_py1",myWatch)#设定监听节点
#当在上面的shell中改变这个节点的数据时，这个shell就会有这样的输出

>>> TypeError: 'str' object is not callable

zk:   /zk_for_py1

zk:   /zk_for_py1