使用python的kazoo模塊連接zookeeper實現最基本的增刪改查

kazoo的官方文檔地址：https://kazoo.readthedocs.io/en/latest/index.html

#!/usr/bin/env python
# -*- coding: utf-8 -*-
""" 
                                                    __----~~~~~~~~~~~------___
                                   .  .   ~~//====......          __--~ ~~
                   -.            \_|//     |||\\  ~~~~~~::::... /~
               ___-==_       _-~o~  \/    |||  \\            _/~~-
        __---~~~.==~||\=_    -_--~/_-~|-   |\\   \\        _/~
    _-~~     .=~    |  \\-_    '-~7  /-   /  ||    \      /
  .~       .~       |   \\ -_    /  /-   /   ||      \   /
 /  ____  /         |     \\ ~-_/  /|- _/   .||       \ /
 |~~    ~~|--~~~~--_ \     ~==-/   | \~--===~~        .\
          '         ~-|      /|    |-~\~~       __--~~
                      |-~~-_/ |    |   ~\_   _-~            /\
                           /  \     \__   \/~                \__
                       _--~ _/ | .-~~____--~-/                  ~~==.
                      ((->/~   '.|||' -_|    ~~-/ ,              . _||
                                 -_     ~\      ~~---l__i__i__i--~~_/
                                 _-~-__   ~)  \--______________--~~
                               //.-~~~-~_--~- |-------~~~~~~~~
                                      //.-~~~--\
                               神獸保佑
                              代碼無BUG!

"""
# zookeeper集群地址
# server.1=192.168.0.162:2888:3888
# server.2=192.168.0.162:2889:3889
# server.3=192.168.0.162:2890:3890


# pip install kazoo

from kazoo.client import KazooClient

# 連接zookeeper
zk = KazooClient(hosts="192.168.0.162:2181,192.168.0.162:2182,192.168.0.162:2183")


# 啟動連接
zk.start()

# 創建
## 創建節點
# zk.ensure_path("/my/favorite")

## 節點添加數據,必須是byte
# zk.create("/my/favorite/node", b"a value")
# zk.create("/my/favorite/name1", b"111111")
# zk.create("/my/favorite/name2", b"222222")

# 獲取節點數據
# data, stat = zk.get("/my/favorite/node")
# print("Version: %s, data: %s" % (stat.version, data.decode("utf-8")))
# Version: 0, data: a value

# 列出節點數據
# children = zk.get_children("/my/favorite")
# print("There are %s children with names %s" % (len(children), children))
# There are 3 children with names ['node', 'name2', 'name1']

# 修改節點數據
# zk.set("/my/favorite/node", b"some data")

# 刪除節點數據
zk.delete("/my/favorite/name2", recursive=True)

# 關閉連接
zk.stop()