gistfile1.txt

import contextlib
import os
import socket
import time

from kazoo import client


def do_hello():
    print("Hello from %s:%s" % (socket.gethostname(), os.getpid()))
    while True:
        time.sleep(5)


def main():
    k_client = client.KazooClient(hosts=os.environ['ZOOKEEPER_HOSTS'])
    k_client.start()
    with contextlib.closing(k_client):
        e = k_client.Election("/hello")
        e.run(do_hello)