@matzeeg3: Kannst du dafür eine kleine Anleitung basteln? Das Script kann auch auf einem Raspi im Heimnetzwerk laufen, korrekt?matzeeg3 hat geschrieben: ↑Do Sep 07, 2023 8:46 am Für alle die auf openWB 1.9 sind ich habe mal das script etwas umgeschrieben.
Danke an cjungde:so müssen keine daten mehr auf http abfrage gestellt werden sondern das script egal ob auf der openwb ausgeführt oder wo anders sendet die daten via mqtt direkt an die openwb. Damit ist auch keine RAMdisk mehr nötig.Code: Alles auswählen
import struct import json import urllib.request import time import ssl import paho.mqtt.client as mqtt ipaddress = "senecip" broker_address = "openwbip or localhost" broker_port = 1883 debug = False #ipaddress = str(sys.argv[1]) client = mqtt.Client() # Verbinden mit dem Broker client.connect(broker_address, broker_port) def myDecode(stringValue): # Parameter: # stringValue: String Wert, im Format Typ_Wert # # Rueckgabe: # result: Floatzahl splitValue = stringValue.split('_') if splitValue[0] == 'fl': #Hex >> Float result = struct.unpack('f',struct.pack('I',int('0x'+splitValue[1],0)))[0] elif splitValue[0] == 'u3': pass #TBD elif splitValue[0] == 'u8': pass #TBD return result def writeVal(stringValue, multiplier, decimalpoints): #Parameter #filePath: Pfad und Dateiname in der der ein Wert geschrieben wird #stringValue: Wert der nach dem knonvertieren in die Datei geschrieben wird #multiplier: Wert mit dem die Zahl vor der Rundung multipliziert wird #decimalpoints: Anzahl Kommastellen # #Rueckgabe: nichts val= myDecode(stringValue) # Format anpassen if multiplier != 0: val = val * multiplier #auf 2 Ziffern runden if decimalpoints == 0: val = int(val) elif decimalpoints != 0: val = round(val,decimalpoints) if val is None: val = 0 return val #EVU Daten reqdata = '{"PM1OBJ1":{"FREQ":"","U_AC":"","I_AC":"","P_AC":"","P_TOTAL":""}}' reqdata = bytes(reqdata, 'utf-8') response = urllib.request.urlopen('https://' + ipaddress + '/lala.cgi', data=reqdata, context=ssl._create_unverified_context()) jsondata = json.load(response) #SENEC: Gesamtleistung (W) Werte -3000 >> 3000 if not (jsondata['PM1OBJ1'] ['P_TOTAL'] is None): topic = "openWB/set/evu/W" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['P_TOTAL'],0,0)) #SENEC: Frequenz(Hz) Werte 49.00 >> 50.00 if not (jsondata['PM1OBJ1'] ['FREQ'] is None): topic = "openWB/set/evu/HzFrequenz" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['FREQ'],0,2)) #SENEC: Spannung (V) Werte 219.12 >> 223.43 if not (jsondata['PM1OBJ1'] ['U_AC'] [0] is None): topic = "openWB/set/evu/VPhase1" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['U_AC'] [0],0,2)) if not (jsondata['PM1OBJ1'] ['U_AC'] [1] is None): topic = "openWB/set/evu/VPhase2" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['U_AC'] [1],0,2)) if not (jsondata['PM1OBJ1'] ['U_AC'] [2] is None): topic = "openWB/set/evu/VPhase3" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['U_AC'] [2],0,2)) #SENEC: Leistung (W) Werte -2345 >> 3000 if not (jsondata['PM1OBJ1'] ['P_AC'] [0] is None): topic = "openWB/set/evu/WPhase1" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['P_AC'] [0],0,0)) if not (jsondata['PM1OBJ1'] ['P_AC'] [1] is None): topic = "openWB/set/evu/WPhase2" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['P_AC'] [1],0,0)) if not (jsondata['PM1OBJ1'] ['P_AC'] [2] is None): topic = "openWB/set/evu/WPhase3" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['P_AC'] [2],0,0)) #SENEC: Strom (A) Werte 0.88 >> 1.67 if not (jsondata['PM1OBJ1'] ['I_AC'] [0] is None): topic = "openWB/set/evu/APhase1" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['I_AC'] [2],0,2)) if not (jsondata['PM1OBJ1'] ['I_AC'] [1] is None): topic = "openWB/set/evu/APhase2" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['I_AC'] [2],0,2)) if not (jsondata['PM1OBJ1'] ['I_AC'] [2] is None): topic = "openWB/set/evu/APhase3" client.publish(topic, writeVal(jsondata['PM1OBJ1'] ['I_AC'] [2],0,2)) #Batteriedaten: reqdata='{"ENERGY":{"GUI_BAT_DATA_FUEL_CHARGE":"","GUI_BAT_DATA_POWER":"","GUI_BAT_DATA_VOLTAGE":"","GUI_BAT_DATA_OA_CHARGING":"","GUI_INVERTER_POWER":""}}' reqdata = bytes(reqdata, 'utf-8') response = urllib.request.urlopen('https://' + ipaddress + '/lala.cgi', data=reqdata, context=ssl._create_unverified_context()) jsondata = json.load(response) #SENEC: Batterieleistung (W) Werte -345 (Entladen) >> 1200 (laden) if not (jsondata['ENERGY'] ['GUI_BAT_DATA_POWER'] is None): topic = "openWB/set/houseBattery/W" client.publish(topic, writeVal(jsondata['ENERGY'] ['GUI_BAT_DATA_POWER'],0,0)) #SENEC: Fuellmenge in Prozent Werte 10 >> 55 >> 100 if not (jsondata['ENERGY'] ['GUI_BAT_DATA_FUEL_CHARGE'] is None): topic = "openWB/set/houseBattery/%Soc" client.publish(topic, writeVal(jsondata['ENERGY'] ['GUI_BAT_DATA_FUEL_CHARGE'],0,0)) #SENEC: Leistung Wechselrichter in (W) Werte if not (jsondata['ENERGY'] ['GUI_INVERTER_POWER'] is None): topic = "openWB/set/pv/1/W" client.publish(topic, writeVal(jsondata['ENERGY'] ['GUI_INVERTER_POWER'],0,0)) # Client beenden client.disconnect()
Im nächsten Step werde ich noch die Berechnung der kWh mit einbauen, das dauert aber leide noch ein paar Tage.
VG Benny
