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

@@ -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:
@@ -41,10 +41,6 @@ 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}")
 
@@ -60,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)
@@ -70,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)
@@ -87,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(