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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
#!/usr/bin/python
##############################################################################
# Copyright (c) 2016 ZTE Coreporation and others.
# hu.zhijiang@zte.com.cn
# lu.yao135@zte.com.cn
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
import yaml
def init(file):
with open(file) as fd:
return yaml.safe_load(fd)
def decorator_mk(types):
def decorator(func):
def wrapter(s):
item_list = s.get(types, [])
result = {}
for item in item_list:
ret = func(item)
item_name = ret.keys().pop()
if result is not None and item_name in result:
result[item_name] = result[item_name] + ret[item_name]
else:
result.update(ret)
return result
return wrapter
return decorator
@decorator_mk('networks')
def network(network=None):
net_plane = network.get('name', '')
if net_plane == "TENANT":
net_plane = "physnet1"
network.pop('name')
map = {}
map[net_plane] = network
return map
@decorator_mk('interfaces')
def interface(interface=None):
net_name = interface.get('name', '')
if net_name == "TENANT":
net_name = "physnet1"
interface_name = interface.get('interface', '')
map2 = {}
map = {'ip': '', 'name': net_name}
map2[interface_name] = [map]
return map2
@decorator_mk('hosts')
def role(host=None):
hostname = host.get('name', '')
role = host.get('roles', '')
map = {}
map[hostname] = role
return map
@decorator_mk('hosts')
def host(host=None):
hostip = host.get('ip', [])
passwd = host.get('password', [])
map = {}
map = {'ip': hostip, 'passwd': passwd}
return map
def network_config_parse(s, dha_file):
network_map = network(s)
vip = s.get('internal_vip')
interface_map = interface(s)
return network_map, vip, interface_map
def dha_config_parse(s, dha_file):
host_role_map = role(s)
hosts_name = []
for name in host_role_map:
hosts_name.append(name)
return hosts_name
def config(dha_file, network_file):
data = init(dha_file)
ceph_disk_name = data.get('ceph_disk_name')
hosts_name = dha_config_parse(data, dha_file)
data = init(network_file)
network_map, vip, interface_map = network_config_parse(data, network_file)
return interface_map, hosts_name, network_map, vip, ceph_disk_name
|
