python docker stats

1
2import docker
3import multiprocessing as mp
4
5output = mp.Queue()
6
7def stats(server):
8    client=docker.from_env()
9    client_lowlevel = docker.APIClient(base_url='unix://var/run/docker.sock')
10    client_stats=client_lowlevel.stats(container=server,decode=True, stream=False)
11    output.put(client_stats)
12
13processes =[ mp.Process(target=stats, args=(server)) for server in ['server1','server2']]
14
15# Run processes
16for p in processes:
17    p.start()
18
19# Exit the completed processes
20for p in processes:
21    p.join()
22
23
24