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
|
#! /usr/bin/env python3
import os
import anyio
import yaml
from iaqualink.client import AqualinkClient
from iaqualink.exception import AqualinkException
async def main():
async with await anyio.open_file(
os.path.expanduser("~/.config/iaqualink.yaml")
) as f:
config = yaml.safe_load(await f.read())
data = {}
async with AqualinkClient(
username=config["username"], password=config["password"]
) as client:
systems = await client.get_systems()
for system, system_obj in systems.items():
data[system] = system_obj.data
try:
devices = await system_obj.get_devices()
except AqualinkException:
pass
else:
data[system]["devices"] = devices
print(yaml.dump(data, default_flow_style=False)) # noqa: T201
if __name__ == "__main__":
import asyncio
asyncio.run(main())
|
