Kazoo安装和使用

kazoo是Python连接操作ZooKeeper的客户端库。我们可以通过kazoo来使用ZooKeeper。

1. 安装

pip install kazoo

 

2. 使用

连接ZooKeeper

  

   

    

     

    
    

     

      from kazoo.client import KazooClient
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      zk = KazooClient(hosts='127.0.0.1:2181')
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # 启动连接
     
    
   

    

     

    
    

     

      zk.start() 
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # 停止连接
     
    
   

    

     

    
    

     

      zk.stop()
     
    
  
 

创建节点

  

   

    

     

    
    

     

      # 创建节点路径，但不能设置节点数据值
     
    
   

    

     

    
    

     

      zk.ensure_path("/my/favorite")
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # 创建节点，并设置节点保存数据，ephemeral表示是否是临时节点，sequence表示是否是顺序节点
     
    
   

    

     

    
    

     

      zk.create("/my/favorite/node", b"a value", ephemeral=True, sequence=True)
     
    
  
 

读取节点

  

   

    

     

    
    

     

      # 获取子节点列表
     
    
   

    

     

    
    

     

      children = zk.get_children("/my/favorite")
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # 获取节点数据data 和节点状态stat
     
    
   

    

     

    
    

     

      data, stat = zk.get("/my/favorite")
     
    
  
 

设置监视

  

   

    

     

    
    

     

      def my_func(event):
     
    
   

    

     

    
    

     
    # 检查最新的节点数据
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      # 当子节点发生变化的时候，调用my_func
     
    
   

    

     

    
    

     

      children = zk.get_children("/my/favorite/node", watch=my_func)
     
    
  
 

文章来源: lansonli.blog.csdn.net，作者：Lansonli，版权归原作者所有，如需转载，请联系作者。

原文链接：lansonli.blog.csdn.net/article/details/104879453