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
|
#!/usr/bin/env python3
import json
import subprocess
def parse_ansible(stdout):
result = {}
errors = set()
for line in stdout.splitlines():
host_name, _ = line.split(" | ", 2)
if " => " not in line:
errors.add(host_name)
continue
_, facts_json = line.split(" => ", 2)
facts = json.loads(facts_json)
result[host_name] = facts
return result, errors
d = subprocess.run(["rye", "run", "ansible","-o", "-m", "setup", "-a", "filter=ansible_distribution", "!k8s"], stdout=subprocess.PIPE, encoding="utf8")
d_data, d_errors = parse_ansible(d.stdout)
v = subprocess.run(["rye", "run", "ansible", "-o", "-m", "setup", "-a", "filter=ansible_distribution_major_version", "!k8s"], stdout=subprocess.PIPE, encoding="utf8")
v_data, v_errors = parse_ansible(v.stdout)
for host_name in d_data.keys():
print(host_name, d_data[host_name]["ansible_facts"]["ansible_distribution"], v_data[host_name]["ansible_facts"]["ansible_distribution_major_version"])
assert not d_errors and not v_errors, (v_errors, d_errors)
|
