After upgrading my opendtu to version 24.3.22 my enclosed python 3 script no longer reads out my Shelly Pro EM3

[muellcy]

After upgrading from version v23.10.9 to v24.3.22 my enclosed attached script is no longer
running as expected.
I also tried the follwing release versions with the same negative result:
v23.12.31 and v24.3.15
After downgrading back to version v23.10.9 everything is back to normal.

Shelley Pro EM3 firmware:
20240223-141900/1.2.2-g7c39781
Opendtu Chip-Modell: ESP32-D0WD-V3
Python 3 Script is executed on Synology NAS: Ds716+II, DMS-Version. 7.2-64570

Details:
The python script is after updating to above mentioned versions no longer able to read out my
Shelly Pro EM3 device. In detail it can not get the „power“ value line 27. With newer opendtu it is „undefined“
See attached screenshot.
Afterwards line 32 is failing because the power value is missing.
The relevant command lines are from 20 to 32.
27 -> power = r['inverters'][0]['AC']['0']['Power']['v'] # Abgabe BKW AC in Watt
32 -> grid_sum = requests.get(f'http://{shelly_ip}/rpc/EM.GetStatus?id=0', headers={'Content-Type': 'application/json'}).json()['total_act_power'] # Aktueller Bezug

Do I have to modify the script to be compatible with releases after v23.10.9?
If yes, what needs to be changed?
Or is this related to a bug in the firmware releases after v23.10.9?

Any feedback is welcome .🙏

Screenshot:

SCRIPT:

#!/usr/bin/env python3
import requests, time, sys
from requests.auth import HTTPBasicAuth

# Diese Daten müssen angepasst werden:
serial = "xxxxxxxxxx" # Seriennummer des Hoymiles Wechselrichters
maximum_wr = 450 # Maximale Ausgabe des Wechselrichters
minimum_wr = 70 # Minimale Ausgabe des Wechselrichters

dtu_ip = '192.168.X.X' # IP Adresse von OpenDTU
dtu_nutzer = 'xxxxx' # OpenDTU Nutzername
dtu_passwort = 'xxxxxxxxx' # OpenDTU Passwort

shelly_ip = '192.168.X.X' # IP Adresse von Shelly Pro 3EM


while True:
    try:
        # Nimmt Daten von der openDTU Rest-API und übersetzt sie in ein json-Format
        r = requests.get(url = f'http://{dtu_ip}/api/livedata/status/inverters' ).json()

        # Selektiert spezifische Daten aus der json response
        reachable = r['inverters'][0]['reachable'] # Ist DTU erreichbar?
        producing = int(r['inverters'][0]['producing']) # Produziert der Wechselrichter etwas?
        altes_limit = int(r['inverters'][0]['limit_absolute']) # Altes Limit
        power_dc = r['inverters'][0]['AC']['0']['Power DC']['v'] # Lieferung DC vom Panel
        power = r['inverters'][0]['AC']['0']['Power']['v'] # Abgabe BKW AC in Watt
    except:
        print('Fehler beim Abrufen der Daten von CMO-openDTU')
    try:
        # Nimmt Daten von der Shelly 3EM pro Rest-API und übersetzt sie in ein json-Format
        grid_sum = requests.get(f'http://{shelly_ip}/rpc/EM.GetStatus?id=0', headers={'Content-Type': 'application/json'}).json()['total_act_power'] # Aktueller Bezug

    except:
        print('Fehler beim Abrufen der Daten von CMO Shelly Pro 3EM')

    # Werte setzen
    print(f'\nBezug: {round(grid_sum, 0)} W, Produktion: {round(power, 0)} W, Verbrauch: {round(grid_sum + power, 0)} W')
    if reachable:
        setpoint = grid_sum + altes_limit - 5 # Neues Limit in Watt
        print(f'neuer Setpoint: {setpoint} W')

        # Fange oberes Limit ab
        if setpoint > maximum_wr:
            setpoint = maximum_wr
            print(f'Setpoint auf Maximum: {maximum_wr} W')
        # Fange unteres Limit ab
        elif setpoint < minimum_wr:
            setpoint = minimum_wr
            print(f'Setpoint auf Minimum: {minimum_wr} W')
        else:
            print(f'Setpoint berechnet: {round(grid_sum, 0)} W + {round(altes_limit, 0)} W - 5 W = {round(setpoint, 0)} W')

        if round(setpoint/50,0) != round(altes_limit/50,0):
        #if setpoint != altes_limit:
            print(f'Setze Inverterlimit von {round(altes_limit, 0)} W auf {round(setpoint, 0)} W... ', end='')
            # Neues Limit setzen
            try:
                r = requests.post(
                    url = f'http://{dtu_ip}/api/limit/config',
                    data = f'data={{"serial":"{serial}", "limit_type":0, "limit_value":{setpoint}}}',
                    auth = HTTPBasicAuth(dtu_nutzer, dtu_passwort),
                    headers = {'Content-Type': 'application/x-www-form-urlencoded'}
                )
                print(f'Konfiguration gesendet ({r.json()["type"]})')
            except:
                print('Fehler beim Senden der Konfiguration')

    sys.stdout.flush() # write out cached messages to stdout
    time.sleep(15) # wait 

[Juergen2453]

Die API hat sich ein wenig geändert.
Neu ist, die Inverter müssen angegeben werden.
/api/livedata/status?inv=inverter-serialnumber

Beispiel:
http ://192.168.10.97/api/livedata/status?inv=1141714xxxxx

Dann müßte es wieder laufen
"r = requests.get(url = f'http://{dtu_ip}/api/livedata/status?inv=xxxxxxxxx' ).json()"

[muellcy]

Besten Dank, dass war es. :-)
Ich habe es via Variable umgesetzt:
"r = requests.get(url = f'http://{dtu_ip}/api/livedata/status?inv={serial}' ).json()"

Damit nimmt er automatisch die Serial No, die in Zeile 5 angegeben wurde.

[muellcy]

Warum auch immer, funktioniert die gestern gemachte Änderung heute nicht mehr mit Version 24.3.22
Fehlermeldung ist wieder die gleiche wie oben angegeben.
Weder wenn ich die Seriennummer direkt angebe oder als variable.
Das ist die einzige Änderung die ich durchgeführt habe:
r = requests.get(url = f'http://{dtu_ip}/api/livedata/status?inv={serial}' ).json()

Warum es gestern funktioniert hat, kann ich nicht mehr nachvollziehen.
Interessanterweise funktioniert das Script mit der oben angepassten Zeile aber noch mit der version 23.10.9

Es scheint so als muss noch an andere Stelle etwas geändert werden.

Wäre echt super wenn sich das jemand noch mal anschauen könnte:

SCRIPT:

#!/usr/bin/env python3
import requests, time, sys
from requests.auth import HTTPBasicAuth

Diese Daten müssen angepasst werden:
serial = "xxxxxxxxxx" # Seriennummer des Hoymiles Wechselrichters
maximum_wr = 450 # Maximale Ausgabe des Wechselrichters
minimum_wr = 70 # Minimale Ausgabe des Wechselrichters

dtu_ip = '192.168.X.X' # IP Adresse von OpenDTU
dtu_nutzer = 'xxxxx' # OpenDTU Nutzername
dtu_passwort = 'xxxxxxxxx' # OpenDTU Passwort

shelly_ip = '192.168.X.X' # IP Adresse von Shelly Pro 3EM

while True:
try:
# Nimmt Daten von der openDTU Rest-API und übersetzt sie in ein json-Format
r = requests.get(url = f'http://{dtu_ip}/api/livedata/status?inv={serial}'  ).json()
    # Selektiert spezifische Daten aus der json response
    reachable = r['inverters'][0]['reachable'] # Ist DTU erreichbar?
    producing = int(r['inverters'][0]['producing']) # Produziert der Wechselrichter etwas?
    altes_limit = int(r['inverters'][0]['limit_absolute']) # Altes Limit
    power_dc = r['inverters'][0]['AC']['0']['Power DC']['v'] # Lieferung DC vom Panel
    power = r['inverters'][0]['AC']['0']['Power']['v'] # Abgabe BKW AC in Watt
except:
    print('Fehler beim Abrufen der Daten von CMO-openDTU')
try:
    # Nimmt Daten von der Shelly 3EM pro Rest-API und übersetzt sie in ein json-Format
    grid_sum = requests.get(f'http://{shelly_ip}/rpc/EM.GetStatus?id=0', headers={'Content-Type': 'application/json'}).json()['total_act_power'] # Aktueller Bezug

except:
    print('Fehler beim Abrufen der Daten von CMO Shelly Pro 3EM')

# Werte setzen
print(f'\nBezug: {round(grid_sum, 0)} W, Produktion: {round(power, 0)} W, Verbrauch: {round(grid_sum + power, 0)} W')
if reachable:
    setpoint = grid_sum + altes_limit - 5 # Neues Limit in Watt
    print(f'neuer Setpoint: {setpoint} W')

    # Fange oberes Limit ab
    if setpoint > maximum_wr:
        setpoint = maximum_wr
        print(f'Setpoint auf Maximum: {maximum_wr} W')
    # Fange unteres Limit ab
    elif setpoint < minimum_wr:
        setpoint = minimum_wr
        print(f'Setpoint auf Minimum: {minimum_wr} W')
    else:
        print(f'Setpoint berechnet: {round(grid_sum, 0)} W + {round(altes_limit, 0)} W - 5 W = {round(setpoint, 0)} W')

    if round(setpoint/50,0) != round(altes_limit/50,0):
    #if setpoint != altes_limit:
        print(f'Setze Inverterlimit von {round(altes_limit, 0)} W auf {round(setpoint, 0)} W... ', end='')
        # Neues Limit setzen
        try:
            r = requests.post(
                url = f'http://{dtu_ip}/api/limit/config',
                data = f'data={{"serial":"{serial}", "limit_type":0, "limit_value":{setpoint}}}',
                auth = HTTPBasicAuth(dtu_nutzer, dtu_passwort),
                headers = {'Content-Type': 'application/x-www-form-urlencoded'}
            )
            print(f'Konfiguration gesendet ({r.json()["type"]})')
        except:
            print('Fehler beim Senden der Konfiguration')

sys.stdout.flush() # write out cached messages to stdout
time.sleep(15) # wait 

[tbnobody]

Setze doch source code einfach in die passenden tags dann wirds auch lesbar :)

Ohne mich genauer mit dem algorithmus beschäftigt zu haben....

Das hier:

power_dc = r['inverters'][0]['AC']['0']['Power DC']['v'] # Lieferung DC vom Panel

Sollte eher das hier sein:

power_dc = r['inverters'][0]['INV']['0']['Power DC']['v'] # Lieferung DC vom Panel

Siehe hier: e156478
Wobei ich gerade sehe, dass die variable sowieso nicht verwendet wird. Es könnte aber einen Fehler beim zugriff auf die variable kommen (weil es den index nicht gibt), dadurch wird der fehler vom try abgefangen und er weißt die power variable nicht zu.

[muellcy]

hmm was muss ich tun um den Index zu setzten? sorry ich bin nicht so tief in der Materie drin, als ich etwas damit anfangen könnte.

[tbnobody]

Einfach die zeilen so ersetzen wie oben beschrieben

[Juergen2453]

Die Zuordnung gibt es nicht, daher gibt es den Fehler.
['AC']['0']['Power DC']
Du gibst mit try: den Fehler aus, das Programm läuft aber weiter, mit den Folgefehler.
Du könntest jetzt "power_dc = xxx" setzen. (Persönlich würde ich es nicht)
oder den Rest der "while " überspringen.

[muellcy]

Ich stehe da auf dem Schlauch. Wenn ich die Änderung von AC auf INV wie oben vorgeschlagen mache, bleibt das Script stehen. Vor der API Änderung hat alles wunderbar funktioniert. Kannst Du mir bitte zeigen, wo ich was im Code anpassen muss. Besten Dank im Voraus

[muellcy]

Das Program läuft nur bis hier...

[tbnobody]

So ist das nur stochern....
Du benötigst ein ordentliches error handling...

Ersetze doch mal die Zeile

except:
    print('Fehler beim Abrufen der Daten von CMO-openDTU')

durch

except Exception as err:
    print('Fehler beim Abrufen der Daten von CMO-openDTU')
    print(f"Unexpected {err=}, {type(err)=}")
    raise

[muellcy]

Das hat geholfen. Typo gefunden. Musste zudem das NAS mal neu starten , damit das Script wieder ordentlich durchläuft. Ich beobachte das jetzt mal ein paar Tage. Gestern hat es ja auch den ganzen Tag funktioniert und dann heute morgen nicht mehr. Auf jeden Fall vielen Dank :-)

[github-actions[bot]]

This discussion has been automatically locked since there has not been any recent activity after it was closed. Please open a new discussion for related concerns.