A python3 compatible library that abstracts the Consul Rest API.
Install it from pypi
pip3 install -i https://test.pypi.org/simple/ ConsulClient==0.1.0Install it using the released python wheel.
wget https://github.com/lozuwa/consul-client/releases/download/0.1.0/ConsulClient-0.1.0-py3-none-any.whl
pip3 install ConsulClient-0.1.0-py3-none-any.whlInput parameters
user="", password="" are to support Basic Auth connections to Consul.
from ConsulClient.ConsulClient import ConsulClient
kvs = {"kafka.bootstrap": "kafka-001:2181", "mongo.host": "mongo:27017"}
consul_client = ConsulClient(host="http://localhost", port="8500", token="", prefix="", user="", password="")
for key, value in kvs.items():
response = self.consul_client.create_update_key(key=key, value=value)
if response["successful_response"] == True:
continue
else:
raise Exception(f"Could not publish {key} {value}")from ConsulClient.ConsulClient import ConsulClient
kvs = {"kafka.bootstrap": "kafka-001:2181", "mongo.host": "mongo:27017"}
consul_client = ConsulClient(host="http://localhost", port="8500", token="", prefix="", user="", password="")
for key, value in kvs.items():
response = self.consul_client.read_key(key=key)
if response["successful_response"] == True:
assert response["body"].get(key) == kvs.get(key), "Value does not exist."
print(response["body"].get(key))
else:
raise Exception(f"Could not read {key}. RC: {response["status_code"]. Error: {response["body"]}}")from ConsulClient.ConsulClient import ConsulClient
kvs = {"kafka.bootstrap": "kafka-001:2181", "mongo.host": "mongo:27017"}
consul_client = ConsulClient(host="http://localhost", port="8500", token="", prefix="dev/", user="", password="")
# Create keys.
for key, value in kvs.items():
response = self.consul_client.create_update_key(key=key, value=value)
params = {"recurse": True}
response = consul_client.read_key(key="dev/", params=params)
if response["successful_response"] == True:
print(response["body"])from ConsulClient.ConsulClient import ConsulClient
kvs = {"kafka.bootstrap": "kafka-001:2181", "mongo.host": "mongo:27017"}
consul_client = ConsulClient(host="http://localhost", port="8500", token="", prefix="", user="", password="")
for key, value in kvs.items():
response = self.consul_client.delete_key(key=key)
if response["successful_response"] == True:
continue
else:
raise Exception(f"Could not delete {key}. RC: {response["status_code"]. Error: {response["body"]}}")Run the following command:
python setup.py sdist bdist_wheel
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent