|
...
|
...
|
@@ -9,6 +9,7 @@ |
|
|
|
import json
|
|
|
|
import os
|
|
|
|
from subprocess import call
|
|
|
|
from jinja2 import Environment, PackageLoader
|
|
|
|
|
|
|
|
|
|
|
|
# clone deploy project to local
|
|
...
|
...
|
@@ -22,8 +23,8 @@ call("mkdir -p %s" % PATH, shell=True) |
|
|
|
call("git clone --recursive git@git.yoho.cn:yohoops/auto_deploy.git %s" % PATH, shell=True)
|
|
|
|
|
|
|
|
|
|
|
|
# get iptables info from git files, parse file format: [yoho_gateway_qcloud_ips=(master@10.66.70.22 master@10.66.70.204 master@10.66.0.240 master@10.66.0.4 master@10.66.0.5)]
|
|
|
|
azs = ['qcloud', 'qcloudaz2', 'qcloudaz3']
|
|
|
|
# get iptables info from git files.
|
|
|
|
azs_mappings = {"qcloud": "az1", "qcloudaz2": "az2", "qcloudaz3": "az3"}
|
|
|
|
host_group = { "yoho_gateway": "java-gateway",
|
|
|
|
"yoho_users": "java-users",
|
|
|
|
"yohobuy_resources": "java-resources",
|
|
...
|
...
|
@@ -33,30 +34,44 @@ host_group = { "yoho_gateway": "java-gateway", |
|
|
|
"yoho_message": "java-message",
|
|
|
|
"yoho_sns": "java-sns"
|
|
|
|
}
|
|
|
|
|
|
|
|
for az in azs:
|
|
|
|
|
|
|
|
fout = open(os.path.join(HOME, ".tmp", az), 'w')
|
|
|
|
fout.write("# inventory file generated by auto_deploy iptables\n")
|
|
|
|
|
|
|
|
file = open(os.path.join(PATH, "scripts/iptable/", az, "app-iptable.sh"), 'r')
|
|
|
|
# all available zone groups
|
|
|
|
all_groups = {}
|
|
|
|
for _az in azs_mappings.keys():
|
|
|
|
groups = {}
|
|
|
|
all_groups[azs_mappings[_az]] = groups
|
|
|
|
file = open(os.path.join(PATH, "scripts/iptable/", _az, "app-iptable.sh"), 'r')
|
|
|
|
for line in file:
|
|
|
|
for g in host_group.keys():
|
|
|
|
if g in line:
|
|
|
|
fout.write("[%s]\n" % host_group[g])
|
|
|
|
for group_name in host_group.keys():
|
|
|
|
if group_name in line:
|
|
|
|
g_hosts = []
|
|
|
|
groups[host_group[group_name]] = g_hosts
|
|
|
|
i_1 = line.index("(")
|
|
|
|
i_2 = line.index(")")
|
|
|
|
sub = line[i_1 + 1 : i_2]
|
|
|
|
for user_ip in sub.split(" "):
|
|
|
|
ip = user_ip[user_ip.index("@") + 1 : ].strip()
|
|
|
|
fout.write("%s\n" % ip)
|
|
|
|
g_hosts.append(user_ip[user_ip.index("@") + 1 : ].strip())
|
|
|
|
|
|
|
|
|
|
|
|
file.close()
|
|
|
|
fout.close()
|
|
|
|
print("success write ansible inventory hosts files to %s " % (os.path.join(HOME, ".tmp", az)))
|
|
|
|
|
|
|
|
print("get all inventory info success. \n")
|
|
|
|
print(all_groups)
|
|
|
|
|
|
|
|
print("success to generate ansible inventory files")
|
|
|
|
## generate az inventory files
|
|
|
|
env = Environment(loader=PackageLoader('inventory'))
|
|
|
|
|
|
|
|
for _az in azs_mappings.keys():
|
|
|
|
az = azs_mappings[_az]
|
|
|
|
|
|
|
|
#backup old file and open new file
|
|
|
|
hosts = os.path.join("./inventories", az, "hosts")
|
|
|
|
call("mv %s %s" % (hosts, os.path.join("./inventories", az, "hosts.bak")), shell=True)
|
|
|
|
file = open(hosts, 'w')
|
|
|
|
|
|
|
|
#write template
|
|
|
|
template = env.get_template('inventory-%s.j2' % az)
|
|
|
|
file.write(template.render(groups = all_groups[az]))
|
|
|
|
file.close()
|
|
|
|
|
|
|
|
|
|
|
|
|
...
|
...
|
|
