simon
/
Inverter_huawei
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Compare commits

base: simon:main
Branches Tags
simon:main
simon:1.0.2
simon:1.0.1
simon:1.0.0
..
compare: simon:1.0.0
Branches Tags
simon:main
simon:1.0.2
simon:1.0.1
simon:1.0.0

No commits in common. "main" and "1.0.0" have entirely different histories.
main ... 1.0.0

2 changed files with 42 additions and 50 deletions
Show Stats Expand all files Collapse all files

3
src/data.py
View File

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

89
src/main.py
View File

@ -4,7 +4,7 @@ import logging
import os import os
import paho.mqtt.client import paho.mqtt.client
from huawei_solar import AsyncHuaweiSolar, ReadException from huawei_solar import AsyncHuaweiSolar
from huawei_solar import register_values as rv from huawei_solar import register_values as rv
from src.data import InverterData, ReadRegister 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") host = os.getenv("INVERTER_HOST", "192.168.200.100")
LOGGER = logging.getLogger(__name__) LOGGER = logging.getLogger(__name__)
REQUEST_INTERVAL = 10 REQUEST_INTERVAL = 60
async def get_inverter_client() -> AsyncHuaweiSolar: async def get_inverter_client() -> AsyncHuaweiSolar:
@ -37,56 +37,51 @@ async def main():
inverter_client = await get_inverter_client() inverter_client = await get_inverter_client()
count = 0 count = 0
while True: while True:
try: status = await inverter_client.get(
status = await inverter_client.get( ReadRegister.inverter_reg_status, slave_id
ReadRegister.inverter_reg_status, slave_id )
)
LOGGER.info(f"-- INVERTER -- Status: {status}") LOGGER.info(f"-- INVERTER -- Status: {status}")
if ( if (
status.value == rv.DEVICE_STATUS_DEFINITIONS.get(0x0200) status.value == rv.DEVICE_STATUS_DEFINITIONS.get(0x0200)
or FORCE_GET or FORCE_GET
): # Inverter is active, Get data ): # Inverter is active, Get data
LOGGER.info("-- INVERTER -- Send measured values") LOGGER.info("-- INVERTER -- Send measured values")
for register in ReadRegister.reg_to_read_measured: for register in ReadRegister.reg_to_read_measured:
result = await get_inverter_data(inverter_client, register) result = await get_inverter_data(inverter_client, register)
send_data( send_data(
mqtt_client, mqtt_client,
format_data_to_serialized_json(result), format_data_to_serialized_json(result),
f"measure/{result.name}", 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)
send_data(
mqtt_client,
format_data_to_serialized_json(result),
f"calculated/{result.name}",
)
if count == 30: # Every 5 min LOGGER.info("-- INVERTER -- Send calculated values")
LOGGER.info("-- INVERTER -- Send status/alarm") for register in ReadRegister.reg_to_read_calculated:
for register in ReadRegister.reg_to_read_status: result = await get_inverter_data(inverter_client, register)
result = await get_inverter_data(inverter_client, register) send_data(
send_data( mqtt_client,
mqtt_client, format_data_to_serialized_json(result),
format_data_to_serialized_json(result), f"calculated/{result.name}",
f"status/{result.name}", )
)
count = 0
else:
LOGGER.debug("-- INVERTER -- Not Active, No need to read values")
count += 1 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)
send_data(
mqtt_client,
format_data_to_serialized_json(result),
f"status/{result.name}",
)
count = 0
else:
LOGGER.debug("-- INVERTER -- Not Active, No need to read values")
LOGGER.info(f"Sleeping {REQUEST_INTERVAL}") count += 1
await asyncio.sleep(REQUEST_INTERVAL)
except ReadException as error: LOGGER.info(f"Sleeping {REQUEST_INTERVAL}")
LOGGER.error(f"Can't read register, {ReadRegister.inverter_reg_status}. " await asyncio.sleep(REQUEST_INTERVAL)
f"Error code: {error}. Sleep for 10 min")
await asyncio.sleep(60) # Sleep 1 min
def send_data( def send_data(