import os
import kazoo.client
import logging

logging.basicConfig(level=logging.DEBUG)

zk_key = "tools/ca/keys/clientkey.pem"
zk_cert = "tools/ca/certs/client.pem"
zk_ca = "tools/ca/certs/cacert.pem"

assert (os.path.exists(zk_ca))
assert (os.path.exists(zk_cert))
assert (os.path.exists(zk_key))

client = kazoo.client.KazooClient(
    hosts='localhost:2281',
    use_ssl=True,
    keyfile=zk_key,
    certfile=zk_cert,
    ca=zk_ca,
)

client.start()
print(client.get('/'))