Advertisement
Guest User

Untitled

a guest
Jul 16th, 2019
76
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.73 KB | None | 0 0
  1. '''
  2. create 节点
  3. 递归创建所有层级的节点,只能设置acl,不能设置data
  4. zk.ensure_path("/my/favorite")
  5.  
  6. 创建节点并设置data
  7. zk.create("/my/favorite/node", b"a value")
  8.  
  9. 读取数据
  10. zk.exists()
  11. zk.get()
  12. zk.get_children()
  13.  
  14. 修改数据
  15. zk.set()
  16.  
  17. 删除节点
  18. zk.delete()
  19.  
  20. 重试&自定义重试
  21. retry,可以多次重复执行一个方法,直到成功,这个函数真是赞
  22. result = zk.retry(zk.get, "/path/to/node")
  23.  
  24. from kazoo.retry import KazooRetry
  25.  
  26. kr = KazooRetry(max_tries=3, ignore_expire=False)
  27. result = kr(client.get, "/some/path")
  28.  
  29. 事务
  30.  
  31. transaction = zk.transaction()
  32. transaction.check('/node/a', version=3)
  33. transaction.create('/node/b', b"a value")
  34. results = transaction.commit()
  35. '''
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement