1import request
2import websockets
3
4# fetch connected devices from the robopipe controller
5cameras = requests.get(f"http://robopipe-1.local").json()
6mxid = cameras[0].get("mxid")
7
8# deploy trained NN
9requests.post(
10    f"http://robopipe-1.local/cameras/{mxid}/streams/CAM_A/nn",
11    files={"model": open("model.blob", "rb")},
12    data={"nn_config": }
13)              
14
15# consume inference websocket stream
16async with websockets.connect(f"ws://robopipe-1.local/cameras/{mxid}/stream/{sensor_name}/nn") as ws: 
17  while True:
18    msg = await ws.recv()
19    print(msg)