Skip to content

Instantly share code, notes, and snippets.

@dougm

dougm/kz-watcher.py

Created April 16, 2013 20:08
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dougm/5399180 to your computer and use it in GitHub Desktop.
Save dougm/5399180 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kz-watcher.py
import time
from kazoo.client import KazooClient
import logging
logging.basicConfig(level=logging.ERROR)
path = "/some/path"
zk = KazooClient()
zk.start()
zk.ensure_path(path)
@zk.DataWatch(path)
def watch_data(data, stat):
print("kz> Version: %s, data: %s" % (stat.version, data.decode("utf-8")))
while True:
time.sleep(1)
zk.stop()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment