python kazoo 监视zookeeper节点数据发生变化

python kazoo 监视zookeeper节点数据发生变化

转载：https://blog.csdn.net/kwsy2008/article/details/52042303

程序可以监视一个zookeeper节点的数据，一旦数据发生变化，监视器会获得相应的消息，利用这种方法，可以对全局的配置进行管理，程序在启动时读取该配置，注册监视器，当数据发生变化时可以获得通知。

      下面的这段代码模拟了该过程

1. #coding=utf-8  
2. from kazoo.client import KazooClient  
3. import time  
4. zk = KazooClient(hosts='127.0.0.1:2181')  
5. zk.start()  
6.  
7. @zk.DataWatch('/kwsy/ss')  
8. def my_func(data, stat, event):  
9.     print("Data is %s" % data)  
10.     print("Version is %s" % stat.version)  
11.     print("Event is %s" % event)  
12.   
13. while True:  
14.     time.sleep(10)  
15.     print 'ok' 
    

通过cli，改变该节点所存储的值，这时程序会得到通知，打印出改变后的信息，注意，在第一次注册的时候，该函数也会被触发。

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！