需求:使用Python操控ZooKeeper


1.由于python客户端依赖c的客户端所以要先安装c版本的客户端
cd zookeeper-3.4.5/src/c
./configure
make 
make install


2.测试c版本客户端,需要gcc和python-devel
./cli_mt localhost:2181
Watcher SESSION_EVENT state = CONNECTED_STATE
Got a new session id: 0x23f9d77d3fe0001


ls /
time = 0 msec
/: rc = 0
consumers
storm
brokers
zookeeper
jobkeeper
time = 0 msec


这样就安装成功了


3.下载python扩展包，并且解压：
地址:https://pypi.python.org/pypi/zkpython/0.4.2




4.如果找不到Pyhon.h，可能由于没有安装python26-devel
32位直接运行
yum install python26-devel.i386




5.测试是否成功


import zookeeper  


如果报错:
>>> import zookeeper
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
ImportError: libzookeeper_mt.so.2: cannot open shared object file: No such file or directory


在shell中配置或者假如/etc/profile文件中:
export LD_LIBRARY_PATH=/usr/local/lib/


6.使用
>>> import zookeeper
>>> hander = zookeeper.init("dc002.tj:2181")
>>> dir(zookeeper) #方法列表
['APIERROR', 'ASSOCIATING_STATE', 'AUTHFAILED', 'AUTH_FAILED_STATE', 'ApiErrorException', 'AuthFailedException', 'BADARGUMENTS', 'BADVERSION', 'BadArgumentsException', 'BadVersionException', 'CHANGED_EVENT', 'CHILD_EVENT', 'CLOSING', 'CONNECTED_STATE', 'CONNECTING_STATE', 'CONNECTIONLOSS', 'CREATED_EVENT', 'ClosingExceHelp on built-in function get in module zookeeper:
ption', 'ConnectionLossException', 'DATAINCONSISTENCY', 'DELETED_EVENT', 'DataInconsistencyException', 'EPHEMERAL', 'EXPIRED_SESSION_STATE', 'INVALIDACL', 'INVALIDCALLBACK', 'INVALIDSTATE', 'InvalidACLException', 'InvalidCallbackException', 'InvalidStateException', 'LOG_LEVEL_DEBUG', 'LOG_LEVEL_ERROR', 'LOG_LEVEL_INFO', 'LOG_LEVEL_WARN', 'MARSHALLINGERROR', 'MarshallingErrorException', 'NOAUTH', 'NOCHILDRENFOREPHEMERALS', 'NODEEXISTS', 'NONODE', 'NOTEMPTY', 'NOTHING', 'NOTWATCHING_EVENT', 'NoAuthException', 'NoChildrenForEphemeralsException', 'NoNodeException', 'NodeExistsException', 'NotEmptyException', 'NothingException', 'OK', 'OPERATIONTIMEOUT', 'OperationTimeoutException', 'PERM_ADMIN', 'PERM_ALL', 'PERM_CREATE', 'PERM_DELETE', 'PERM_READ', 'PERM_WRITE', 'RUNTIMEINCONSISTENCY', 'RuntimeInconsistencyException', 'SEQUENCE', 'SESSIONEXPIRED', 'SESSIONMOVED', 'SESSION_EVENT', 'SYSTEMERROR', 'SessionExpiredException', 'SessionMovedException', 'SystemErrorException', 'UNIMPLEMENTED', 'UnimplementedException', 'ZooKeeperException', '__doc__', '__file__', '__name__', '__package__', '__version__', 'acreate', 'add_auth', 'adelete', 'aexists', 'aget', 'aget_acl', 'aget_children', 'aset', 'aset_acl', 'async', 'client_id', 'close', 'create', 'delete', 'deterministic_conn_order', 'exists', 'get', 'get_acl', 'get_children', 'init', 'is_unrecoverable', 'recv_timeout', 'set', 'set2', 'set_acl', 'set_debug_level', 'set_log_stream', 'set_watcher', 'state', 'zerror']


#测试get命令
>>> zookeeper.get(hander,"/jobkeeper/gamedc/job/kpi-day-pay_day")
('{"dependency":[{"name":"etl-day-pay_log","type":"day"}],"name":"kpi-day-pay_day","owner":"dc","path":"${SCRIPTS_HOME}/kpi/pay/pay_day.sh","type":"day","hour":"01"}', {'pzxid': 4298844949L, 'ctime': 1411896174285L, 'aversion': 0, 'mzxid': 4299652800L, 'numChildren': 0, 'ephemeralOwner': 0L, 'version': 2, 'dataLength': 163, 'mtime': 1412055214425L, 'cversion': 0, 'czxid': 4298844949L})




#其他的delete,set可以自己测试了,都是api