Added exeption for all reading

src/data.py

@@ -20,6 +20,9 @@ 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

@@ -4,7 +4,7 @@ import logging
 import os
 
 import paho.mqtt.client
-from huawei_solar import AsyncHuaweiSolar
+from huawei_solar import AsyncHuaweiSolar, ReadException
 from huawei_solar import register_values as rv
 
 from src.data import InverterData, ReadRegister
@@ -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 = 60
+REQUEST_INTERVAL = 10
 
 
 async def get_inverter_client() -> AsyncHuaweiSolar:
@@ -37,6 +37,7 @@ async def main():
     inverter_client = await get_inverter_client()
     count = 0
     while True:
+        try:
             status = await inverter_client.get(
                 ReadRegister.inverter_reg_status, slave_id
             )
@@ -55,7 +56,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)
@@ -65,7 +66,7 @@ async def main():
                             f"calculated/{result.name}",
                         )
 
-        if count == 5:
+            if count == 30:  # Every 5 min
                 LOGGER.info("-- INVERTER -- Send status/alarm")
                 for register in ReadRegister.reg_to_read_status:
                     result = await get_inverter_data(inverter_client, register)
@@ -82,6 +83,10 @@ 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(