Zookeeper学习笔记 --- Py

# -*- coding:utf-8 -*-
__author__ = 'yangxin'

from kazoo.client import KazooClient

class PyZooConn(object):
    # init function include connection method
    def __init__(self):
        self.zk = KazooClient(hosts='localhost:2182')
        self.zk.start()

    # get node data
    def get_data(self, param):
        result = self.zk.get(param)
        print result

    # create a node and input a value in this node
    def create_node(self, node, value):
        self.zk.create(node, value)


    # close the connection
    def close(self):
        self.zk.stop()

    '''
    Hypothesis there is a bunch of methods here haha :)
    '''

if __name__ == '__main__':
    pz = PyZooConn()
    pz.create_node("/test", "a value")
    pz.get_data("/test/")
    pz.close()

# -*- coding:utf-8 -*-
__author__ = 'yangxin'
import zookeeper as zoo
import os


class PyZookeeper(object):
    def __init__(self):
        zk_address = os.environ.get("192.168.1.1:2181")
        self.zk = zoo.init(zk_address)

    def create_node(self, node, key,value):
        self.zk.create(node, key, value)

    def get(self, node, key):
        self.zk.get("/test", key)

    '''
    Hypothesis there is a bunch of methods here haha :)
    '''

if __name__ == '__main__':
    py_zoo = PyZookeeper()
    py_zoo.create_node("","", "")
    py_zoo.get("","")