1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
import base64
import json
import requests
def get_configuration(consul_host, consul_port, key):
url = "http://{}:{}/v1/kv/{}".format(consul_host, consul_port, key)
req = requests.get(url)
if req.status_code != 200:
raise Exception("xxx")
data = req.json()
if len(data) == 1:
data = data[0]
return {data["Key"]: json.loads(base64.b64decode(data["Value"]).decode("utf-8"))}
else:
return [
{item["Key"]: json.loads(base64.b64decode(item["Value"]).decode("utf-8"))}
for item in data
]
def get_config_data(consul_host, consul_port):
conf_data = dict()
conf_data['manager_host'] = get_configuration(consul_host, consul_port,
'components/manager')['components/manager']['external']['hostname']
conf_data['manager_port'] = get_configuration(consul_host, consul_port,
'components/manager')['components/manager']['external']['port']
# conf_data['authz_host'] = get_configuration(consul_host, consul_port,
# 'components/interface')['components/interface']['external']['hostname']
# conf_data['authz_port'] = get_configuration(consul_host, consul_port,
# 'components/interface')['components/interface']['external']['port']
conf_data['keystone_host'] = get_configuration(consul_host, consul_port,
'openstack/keystone')['openstack/keystone']['external']['url']
# conf_data['keystone_port'] = '5000'
conf_data['keystone_user'] = get_configuration(consul_host, consul_port,
'openstack/keystone')['openstack/keystone']['user']
conf_data['keystone_password'] = get_configuration(consul_host, consul_port,
'openstack/keystone')['openstack/keystone']['password']
conf_data['keystone_project'] = get_configuration(consul_host, consul_port,
'openstack/keystone')['openstack/keystone']['project']
return conf_data
# get_conf_data('88.88.88.2', '30005')
# get_conf_data('127.0.0.1', 8082)
|
