python腳本測試
# -*- coding:utf-8 -*-
from kazoo.client import KazooClient
class PyZooConn(object):
# init function include connection method
def __init__(self):
self.zk = KazooClient(hosts='192.168.4.170:30405')
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()
if __name__ == '__main__':
path = "/abc/abc"
value = b"peter"
pz = PyZooConn()
pz.create_node(path, value)
pz.get_data(path)
pz.close()
壓測
1.運(yùn)行一個zk的壓力測試容器
docker run --rm --name ztest -it daocloud.io/daocloud/zookeeper:feature-pressure_test /bin/bash
2.編輯配置文件
vi benchmark.conf（修改zookeeper服務(wù)器地址以及其他相關(guān)參數(shù)）
3.運(yùn)行測試工具
./runBenchmark.sh test1111 ./benchmark.conf
robot腳本
*** Settings ***
Library XML
library ZookeeperLibrary
*** Variable ***
${aa}
*** Test Cases ***
aaa
ZookeeperLibrary.Connect To Zookeeper 192.168.124.115:12181
${aa} ZookeeperLibrary.Get Value /abc
BuiltIn.Log ${aa}
