3pp-mirror/ahoy
1
0
Fork 0
mirror of https://github.com/lumapu/ahoy.git synced 2025-04-30 02:36:20 +02:00
Code Issues Projects Releases Packages Wiki Activity

RPI move function MQTT-Output as class method

Browse source 
RPI move function MQTT-Output as class method to outputs.py
This commit is contained in:
Knuti_in_Päse 2023-01-11 15:13:00 +01:00 • committed by GitHub
parent 52e8d98319
commit dcfd966fe4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
tools/rpi/hoymiles/__main__.py
View file

@ -187,14 +187,16 @@ def poll_inverter(inverter, dtu_ser, do_init, retries):
command_queue[inv_str].append(hoymiles.compose_send_time_payload(InfoCommands.AlarmData, alarm_id=event_message_index[inv_str])) command_queue[inv_str].append(hoymiles.compose_send_time_payload(InfoCommands.AlarmData, alarm_id=event_message_index[inv_str]))
if mqtt_client: if mqtt_client:
mqtt_send_status(mqtt_client, inverter_ser, data, # mqtt_send_status(mqtt_client, inverter_ser, data, topic=inverter.get('mqtt', {}).get('topic', None))
topic=inverter.get('mqtt', {}).get('topic', None)) mqtt_client.store_status(result, topic=inverter.get('mqtt', {}).get('topic', None))
if influx_client: if influx_client:
influx_client.store_status(result) influx_client.store_status(result)
if volkszaehler_client: if volkszaehler_client:
volkszaehler_client.store_status(result) volkszaehler_client.store_status(result)
"""
def mqtt_send_status(broker, inverter_ser, data, topic=None): def mqtt_send_status(broker, inverter_ser, data, topic=None):
""" """
Publish StatusResponse object Publish StatusResponse object
@ -238,6 +240,7 @@ def mqtt_send_status(broker, inverter_ser, data, topic=None):
broker.publish(f'{topic}/temperature', data['temperature']) broker.publish(f'{topic}/temperature', data['temperature'])
if data['energy_total'] is not None: if data['energy_total'] is not None:
broker.publish(f'{topic}/total', data['energy_total']/1000) broker.publish(f'{topic}/total', data['energy_total']/1000)
"""
def mqtt_on_command(client, userdata, message): def mqtt_on_command(client, userdata, message):
""" """