1

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()
4

1 に答える 1