我想使用 kazoo 客户端在 Python 中节点的所有子节点上添加监视,但ChildrenWatch
只监视子添加或删除,而不监视任何子节点的数据更新。我正在寻找一个简单的食谱来完成这项任务。
示例代码将是这样的
from kazoo.client import KazooClient
zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()
@zk.SomeRecipe("/root")
def watch_children_update(event):
print("Updated child at path:%s data:%s stat:%s" % event.path, event.data, event.stat)
from kazoo.client import KazooClient
@client.DataWatch('/path/to/watch')
def my_func(data, stat):
print("Data is %s" % data)
print("Version is %s" % stat.version)
# Or if you want the event object
@client.DataWatch('/path/to/watch')
def my_func(data, stat, event):
print("Data is %s" % data)
print("Version is %s" % stat.version)
print("Event is %s" % event)
你需要的是数据观察
节点
下的子节点已更改(已添加或删除子节点)。此事件并不表示子节点的数据已更改,子节点必须建立自己的监视。