如何使用kazoo停止动物园管理员节点上的数据访问？

Question

如何使用python模块kazoo显式停止在zNode上启动的datawatch进程？下面是我创建datawatch的方式

from   kazoo.recipe.watchers    import DataWatch
datawatch = DataWatch(client=zookeeper_client, path=path_to_znode, func=callback_function)

我浏览了kazoo wiki并找出了下面的方法。

1. 从传递的回调方法返回False (此处为callback_function)将停止zNode上的数据仓库。但是这种方式不适合我，因为callback_function是由用户处理的，而不是在我手中。
2. 当进程停止时，datawatch会自动被杀死。但我不想阻止这个过程。
3. 这是我目前使用的讨厌的方式。datawatch类下有一个私有成员变量"_stopped“。我要证明这是真的。 datawatch._stopped =真

有人能在这里提出更好的解决方案吗。谢谢。

Answer 1

DataWatch医生还说：

如果客户端连接被关闭(使用close命令)，DataWatch将不再获得更新。所以停止动物园管理员客户应该就足够了。

from kazoo.client import KazooClient

zk = KazooClient(hosts='127.0.0.1:2181')
zk.start()
datawatch = DataWatch(client=zk, path=path_to_znode, func=callback_function)
# time pass....
zk.stop()