src/data.py

@@ -20,9 +20,6 @@ class ReadRegister:
         rn.PV_02_VOLTAGE,
         rn.PV_01_CURRENT,
         rn.PV_02_CURRENT,
-        rn.PHASE_A_CURRENT,
-        rn.PHASE_B_CURRENT,
-        rn.PHASE_C_CURRENT,
         rn.INPUT_POWER,
         rn.ACTIVE_POWER,
         rn.GRID_CURRENT,

src/main.py

@@ -22,7 +22,7 @@ port = os.getenv("INVERTER_PORT", 502)
 host = os.getenv("INVERTER_HOST", "192.168.200.100")
 
 LOGGER = logging.getLogger(__name__)
-REQUEST_INTERVAL = 10
+REQUEST_INTERVAL = 60
 
 
 async def get_inverter_client() -> AsyncHuaweiSolar:
@@ -41,6 +41,10 @@ async def main():
             status = await inverter_client.get(
                 ReadRegister.inverter_reg_status, slave_id
             )
+        except ReadException as error:
+            LOGGER.error(f"Can't read register, {ReadRegister.inverter_reg_status}. "
+                         f"Error code: {error}. Sleep for 10 min")
+            await asyncio.sleep(10*60)
 
         LOGGER.info(f"-- INVERTER -- Status: {status}")
 
@@ -56,7 +60,7 @@ async def main():
                     format_data_to_serialized_json(result),
                     f"measure/{result.name}",
                 )
-                if count == 6:  # Every 1 min
+
             LOGGER.info("-- INVERTER -- Send calculated values")
             for register in ReadRegister.reg_to_read_calculated:
                 result = await get_inverter_data(inverter_client, register)
@@ -66,7 +70,7 @@ async def main():
                     f"calculated/{result.name}",
                 )
 
-            if count == 30:  # Every 5 min
+        if count == 5:
             LOGGER.info("-- INVERTER -- Send status/alarm")
             for register in ReadRegister.reg_to_read_status:
                 result = await get_inverter_data(inverter_client, register)
@@ -83,10 +87,6 @@ async def main():
 
         LOGGER.info(f"Sleeping {REQUEST_INTERVAL}")
         await asyncio.sleep(REQUEST_INTERVAL)
-        except ReadException as error:
-            LOGGER.error(f"Can't read register, {ReadRegister.inverter_reg_status}. "
-                         f"Error code: {error}. Sleep for 10 min")
-            await asyncio.sleep(60)  # Sleep 1 min
 
 
 def send_data(