kazoo_zookeeper_connect_create_read_node_quickstart.py

1from kazoo.client import KazooClient
2
3# Create a client and start the connection
4zk = KazooClient(hosts='127.0.0.1:2181')
5zk.start()
6
7# Ensure a path exists, create nodes if necessary
8zk.ensure_path("/my/favorite")
9
10# Create a node with data
11zk.create("/my/favorite/node", b"a value")
12
13# Determine if a node exists
14if zk.exists("/my/favorite/node"):
15    # Get the data and its status for a node
16    data, stat = zk.get("/my/favorite/node")
17    print("Version: %s, data: %s" % (stat.version, data.decode("utf-8")))
18
19    # List the children
20    children = zk.get_children("/my/favorite")
21    print("There are %s children with names %s" % (len(children), children))
22
23# Stop the connection
24zk.stop()