Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- '''
- create 节点
- 递归创建所有层级的节点,只能设置acl,不能设置data
- zk.ensure_path("/my/favorite")
- 创建节点并设置data
- zk.create("/my/favorite/node", b"a value")
- 读取数据
- zk.exists()
- zk.get()
- zk.get_children()
- 修改数据
- zk.set()
- 删除节点
- zk.delete()
- 重试&自定义重试
- retry,可以多次重复执行一个方法,直到成功,这个函数真是赞
- result = zk.retry(zk.get, "/path/to/node")
- from kazoo.retry import KazooRetry
- kr = KazooRetry(max_tries=3, ignore_expire=False)
- result = kr(client.get, "/some/path")
- 事务
- transaction = zk.transaction()
- transaction.check('/node/a', version=3)
- transaction.create('/node/b', b"a value")
- results = transaction.commit()
- '''
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement