kazooのドキュメントを読みました。次に、サイトでコード例を実行しました。実行するたびに watch の func が呼び出されました。1 つのノードの子が削除されるまでプログラムをブロックしたいのですが、どうすればよいですか?
現在のコード:
#!/usr/bin/env python3
from kazoo.client import KazooClient
zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()
@zk.ChildrenWatch("/distribute-lock")
def watch_children(children):
print("Children are now: %s" % children)
children = zk.exists("/distribute-lock/childnode-325", watch=watch_children)
print(children)
zk.stop()