run for all sensors

poll.py

@@ -1,5 +1,6 @@
 import asyncio
 import json
+import logging
 import os
 
 import websockets
@@ -11,6 +12,11 @@
 
 load_dotenv()  # Take environment variables from .env. See .env.example.
 
+# Setup logging
+logging.basicConfig()
+logger = logging.getLogger("poll")
+logger.setLevel(logging.INFO)
+
 INFLUXDB_TOKEN = os.environ["INFLUXDB_TOKEN"]
 INFLUXDB_URL = os.environ["INFLUXDB_URL"]
 INFLUXDB_ORG = os.environ["INFLUXDB_ORG"]
@@ -26,15 +32,16 @@
 
 async def poll_once(host):
     uri = f"ws://{host['address']}"
-    print(uri)
-    async with websockets.connect(uri) as websocket:
-        print(f"connected to {uri}")
+    logger.info("Connecting to '%s' at '%s'", host["name"], uri)
 
+    async with websockets.connect(uri) as websocket:
         # Ask for all sensor values
         await websocket.send("J1.15S\r")
         message = await websocket.recv()
         sensor_data = parse_sensor_data(message.decode("utf-8"))
+        logger.debug("'%s' readings: %s", host["name"], sensor_data)
 
+        # Assemble message for InfluxDB
         sequence = []
         for field in sensor_data:
             sequence.append(f"{field},host={uri} {field}={sensor_data[field]}")

reactors.json

@@ -3,17 +3,17 @@
         {
             "id":0,
             "address":"192.168.1.241",
-            "name":"blue"
+            "name":"red"
         },
         {
             "id":1,
             "address":"192.168.1.242",
-            "name":"red"
+            "name":"purple"
         },
         {
             "id":2,
             "address":"192.168.1.243",
-            "name":"purple"
+            "name":"blue"
         }
     ]
 }