Mein neues Projekt, Data von .json auslesen und weiter verwenden

gwaag · Nov 9th 2022

Hallo bitte brauche nochmals Hilfe fuer eine json liste die etwas anderst strukturiert ist wie die von Beitrag 5.

Wie filtere ich "emeters" und "power" im ersten Element, damit ich ihn weiter verarbeiten kann mit z.B print.

Blicke da immer noch nicht ganz durch.

Code

{

 "emeters": [
        {
            "power": 14.41,
            "reactive": -90.57,
            "pf": -0.16,
            "voltage": 234.14,
            "is_valid": true,
            "total": 310009.9,
            "total_returned": 0.0
        },
        {
            "power": 0.0,
            "reactive": 0.0,
            "pf": 0.0,
            "voltage": 234.14,
            "is_valid": true,
            "total": 0.0,
            "total_returned": 0.0
        }
    ],
    "update": {
        "status": "pending",
        "has_update": true,
        "new_version": "20221027-105518/v1.12.1-ga9117d3",
        "old_version": "20220809-125130/v1.12-g99f7e0b"
    },
    "ram_total": 51072,
    "ram_free": 35832,
    "fs_size": 233681,
    "fs_free": 157377,
    "uptime": 3296604

Display More

Tell · Nov 9th 2022

Code

print( obj["emeters"][0]["power"] )

gwaag · Nov 9th 2022

Ja das funktioniert so, haette ich auch selber drauf kommen koennen.

Danke Dir fuer die Hilfe.

Gruss

gwaag

gwaag · Nov 9th 2022

Print hat funktioniert , jetzt im script kommt aber ein error:

Code

pi@solaranzeige:~/th $ /home/pi/th/test_shelly.py
Traceback (most recent call last):
  File "/home/pi/th/test_shelly.py", line 25, in <module>
    obj = response.json()
  File "/usr/lib/python3/dist-packages/requests/models.py", line 897, in json
    return complexjson.loads(self.text, **kwargs)
  File "/usr/lib/python3/dist-packages/simplejson/__init__.py", line 518, in loads
    return _default_decoder.decode(s)
  File "/usr/lib/python3/dist-packages/simplejson/decoder.py", line 370, in decode
    obj, end = self.raw_decode(s)
  File "/usr/lib/python3/dist-packages/simplejson/decoder.py", line 400, in raw_decode
    return self.scan_once(s, idx=_w(s, idx).end())
simplejson.errors.JSONDecodeError: Expecting value: line 1 column 1 (char 0)

Display More

script:

Python

#!/usr/bin/env python3


from socket import socket, AF_INET, SOCK_DGRAM
import json
import requests
import time
from time import sleep

def send_command(cmd, ip, port):
    with socket(AF_INET, SOCK_DGRAM) as sock:
        addr = (ip, port)
        sock.sendto(cmd, addr)

ZONE1_ON=b"\x42\x00\x55"
ZONE1_OFF=b"\x46\x00\x55"

IP="192.168.0.20"
PORT=8899

# Raumtemperatur Wohnen west, auslesen

response = requests.get("http://192.168.0.23/status")

obj = response.json()

print (obj ["emeters"][0]["power"])

low =  obj ["emeters"][0]["power"]<= 20.0
high =  obj ["emeters"][0]["power"]>= 400

# test mit lampe
if low:
    send_command(ZONE1_ON, IP, PORT)
    sleep(2)
if high:
    send_command(ZONE1_OFF, IP, PORT)

Display More

Code

gwaag · Nov 9th 2022

Sorry, Fehler gefunden, falsche IP adresse.

gwaag · Nov 10th 2022

In meinem script funktioniert schon an verschiedenen Stellen das logging .

Wie kann ich den Wert der mit print ausgegeben wird in die .log Datei schreiben?

Code

 print(raum["sensoren"][1]["wert"])
 logging.info('Watt') # Logeintrag???????

keepfear · Nov 10th 2022

Ich würde sagen in dem du die Abfrage des jeweiligen Wertes mit ins Log nimmst.

Python

 print(raum["sensoren"][1]["wert"])

 logging.info(f"Watt: {raum["sensoren"][1]["wert"]}")

ich weiß jetzt aber nicht was das logging-Modul noch bereit hält.

gwaag · Nov 10th 2022

Danke fuer die schnelle Rueckmeldung.

Leider kommt ein Fehler. Fuer was ist das f in (f " Watt : ?

Code

pi@solaranzeige:~/th $ /home/pi/th/SG_Ready.py
  File "/home/pi/th/SG_Ready.py", line 68
    logging.info(f"Watt: {raum["sensoren"][1]["wert"]}")  # Logeintrag
                                       ^
SyntaxError: invalid syntax
pi@solaranzeige:~/th $

keepfear · Nov 10th 2022

Python

logging.info(f"Watt: {raum['sensoren'][1]['wert']}")

Man kann statt er format-Methode auch f-String benutzen.

Dennis89 · Nov 10th 2022

Hallo,

du musst auf die Anführungszeichen achten:

f'Watt: {raum["sensoren"][1]["wert"]}'

Grüße

Dennis

Edit: Zu langsam

gwaag · Nov 10th 2022

Und schon gehts

Danke Euch-

Code

Woche 45 Do 10.11.2022 10:50:02 gelbw
Woche 45 Do 10.11.2022 10:51:01 gelbw
Woche 45 Do 10.11.2022 10:52:01 gelbw
Woche 45 Do 10.11.2022 10:53:02 gelbw
Woche 45 Do 10.11.2022 10:54:02 gelbw
Woche 45 Do 10.11.2022 10:54:49 Watt: 20.600000381469727
Woche 45 Do 10.11.2022 10:55:02 gelbw

keepfear · Nov 10th 2022

Du könntest den Wert noch Runden:

Python

logging.info(f"Watt: {round(raum['sensoren'][1]['wert'], 1)}")

Statt der 1 nach dem Komma, kannst du auch 2 oder 3 usw. angeben. Das sind dann die Stellen nach dem Komma.

__blackjack__ · Nov 10th 2022

Wobei man da eher die Möglichkeiten der Zeichenkettenformatierung statt `round()` verwendet:

Python

logging.info(f"Watt: {raum['sensoren'][1]['wert']:.1f}")

Allerdings würde man beim Logging auch eher gar nicht selbst formatieren, sondern eine Zeichenkettenvorlage mit %-Platzhaltern und den/die Wert(e) getrennt übergeben:

Python

logging.info("Watt: %.1f", raum["sensoren"][1]["wert"])

Dann wird nur in Zeichenkette umgewandelt/formatiert wenn auch tatsächlich protokolliert wird.

gwaag · Nov 10th 2022

Funktioniert, Danke.

Code

 print (obj ["emeters"][0]["power"])
 logging.info(f"Watt: {round(obj ['emeters'][0]['power'], 2)}")  # Logeintrag

Code

 print(raum["sensoren"][1]["wert"])
 logging.info(f"Temp: {round(raum['sensoren'][1]['wert'], 2)}")  # Logeintrag

Code

Woche 45 Do 10.11.2022 12:18:34 SG-Ready bit1 aus1 -500
Woche 45 Do 10.11.2022 12:18:35 SG-Ready bit2 aus1 -500
Woche 45 Do 10.11.2022 12:19:10 Watt: 608.77
Woche 45 Do 10.11.2022 12:19:33 Temp: 20.76
Woche 45 Do 10.11.2022 12:19:33 SG-Ready bit1 aus1 -500
Woche 45 Do 10.11.2022 12:19:34 SG-Ready bit2 aus1 -500
Woche 45 Do 10.11.2022 12:20:33 Temp: 20.76

gwaag · Nov 11th 2022

Hallo,

was könnte der Grund sein dass der log 8x in der gleichen sec, den log füllt?

Meine Schleife fragt das script alle min. ab.

Python

#!/usr/bin/env python3

import json
import requests
import logging
import locale
import datetime
from datetime import datetime
import http.client
import time
from time import sleep
from influxdb import InfluxDBClient


while True:
    sleep(30)

    locale.setlocale(locale.LC_ALL, 'de_DE.utf8')
    logging.basicConfig(filename='/home/pi/th/ms.log', format='%(asctime)s %(message)s', datefmt="Woche %V %a %d.%m.%Y %H:%M:%S",
    level=logging.INFO)

# Zeitfenster

    now = datetime.now()
    Now = now.hour * 60 + now.minute

    timewindow1 = (9*60+0) <= Now < (16*60+0)    # ein
    timewindow2 = (16*60+1) <= Now < (17*60+1)   # aus

    timewindow3 = (20*60+0) <= Now < (23*60+0)   # ein  Nachtbooster
    timewindow4 = (23*60+1) <= Now < (23*60+2)   # aus  Nachtbooster

    timewindow5 = (23*60+5) <= Now < (23*60+6)   # ein  Nachtabsenkung
    timewindow6 = (7*60+0) <= Now < (7*60+1)     # aus  Nachtabsenkung


# Periode Winter oder Sommer

    monat = datetime.now().month
    sommer = monat >= 3 and monat <= 9
    winter = not (sommer)

# Enspeisung Influx auslesen

    client = InfluxDBClient(host='192.168.0.29', port=8086)   # ip oder localhost
    client.switch_database('zaehler')

    results = client.query('SELECT "Gesamtleistung" FROM "AC" GROUP BY * ORDER BY DESC LIMIT 1')
    points = results.get_points
    point = 0
    for point in points():
        shelly_eks = point['Gesamtleistung']

    einspeisung = shelly_eks


# Raumtemperatur auslesen (Wohnzimmer west / Controme)

    response = requests.get("http://192.168.0.23/get/json/v1/1/temps/")

    obj = response.json()

    for raum in obj[0]["raeume"]:
        if raum ["name"] == "Wohnen west":
            if raum ["sensoren"][1]["wert"]:
                print(raum["sensoren"][1]["wert"])

                logging.info("Temp: %.2f", raum ["sensoren"][1]["wert"])  # Logeintrag

        zu_kalt = raum ["sensoren"][1]["wert"]<= 20.5
        zu_warm = raum ["sensoren"][1]["wert"]>= 21.5


# Shel1y WP_Verbrauch auslesen

    response = requests.get("http://192.168.0.140/status")

    obj = response.json()

    print (obj ["emeters"][0]["power"])

    low = obj ["emeters"][0]["power"] <= 20
    high = obj ["emeters"][0]["power"] >= 400

# Signal, dass WP Startet

    if (obj ["emeters"][0]["power"]) > 50 and (obj ["emeters"][0]["power"]) < 250:
        sleep(5)
        logging.info('WP StartStartStartStartStart') # Logeintrag

#  bit1 IP .150 /  bit2 IP .151

# SG-Ready  Scenario 1 1  ON / ON  Leistung Max  110%

    if winter and einspeisung <= -1500 and timewindow1:                  # 9-16h
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=on") # Closed
        logging.info('SG-Ready bit2 ein -1500') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=on") # Closed
        logging.info('SG-Ready bit1 ein -1500') # Logeintrag
        sleep(3600)    # Minimum 1h eingeschaltet
        logging.info('SG-Ready sleep') # Logeintrag

# SG-Ready Aus Scenario 0 0  OFF / OFF  Normalbetrieb

    if winter and einspeisung > -100 and timewindow1:                     # 9-16h
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit1 aus1 -500') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit2 aus1 -500') # Logeintrag
        sleep(1800)


# SG-Redy Aus

    if winter and timewindow2:                                             # 17h
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit1 aus2 -500') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit2 aus2 -500') # Logeintrag
        sleep(1)


# Nachtbooster Ein/Aus

# SG-Ready  Scenario 1 1  ON / ON  Leistung Max (110%)   (110% muss in Panasonic WP gessetzt sein)


    if winter and timewindow3 and zu_kalt:         # < 20.5               # 20h
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=on") # Closed
        logging.info('SG-Ready Nb bit2 ein 20:00h') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=on") # Closed
        logging.info('SG-Ready Nb bit1 ein 20:00h') # Logeintrag

    if winter and timewindow4:                                            # 23h
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready Nb bit1 aus 23:00h') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready Nb bit2 aus 23:00h') # Logeintrag


# Nachtabsenkung  Ein/Aus

# SG-Ready  Scenario 0 1  OFF / ON  Leistung Min (95%)   (95% muss in Panasonic WP gessetzt sein)


    if winter and timewindow5 and zu_warm:         # > 21.5Â°              # 23.05h
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=on") # Closed
        logging.info('SG-Ready bit2 ein 23:050h') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit1 aus 23:05h') # Logeintrag

    if winter and timewindow6:                                            # 7h
        conn = http.client.HTTPConnection("[192.168.0.150]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit1 aus 7:00h') # Logeintrag
        sleep(1)
        conn = http.client.HTTPConnection("[192.168.0.151]")
        conn.request("GET", "/relay/0?turn=off") # Open
        logging.info('SG-Ready bit2 aus 7:00h') # Logeintrag

Display More

Code

Woche 45 Fr 11.11.2022 14:53:34 Watt: 460.97
Woche 45 Fr 11.11.2022 14:53:34 Watt: 460.97
Woche 45 Fr 11.11.2022 14:53:38 Watt: 461.61
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:39 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:40 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:40 Watt: 464.51
Woche 45 Fr 11.11.2022 14:53:47 Watt: 457.90
Woche 45 Fr 11.11.2022 14:53:47 Watt: 457.90

Display More

keepfear · Nov 11th 2022

Ich finde das etwas unübersichtlich.

Wie wärs denn, wenn du das alles mal in Funktionen baust?

Du könntest dann auch das schedule-Modul nehmen, um die abfragen an zustoßen.

gwaag · Nov 11th 2022

Danke fuer Deine Antwort.

Immer wenn ich ein script poste, sagen alle man versteht es nicht, ist nicht übersichtlich. Mit den Kommentaren sollte man doch verstehen was es macht.

Ich bin kein Programmierer und das was ich hier programmiere kommt von dem was ich früher mit SPS programmiert habe, anders istt es für mich ja noch komplizierter

Trotzdem eine Idee warum der log Eintrag nicht nur alle 30 sec. erfolgt?

Dennis89 · Nov 11th 2022

Quote from gwaag

was könnte der Grund sein dass der log 8x in der gleichen sec, den log füllt?

Mit dem gezeigten Skript? Ich finde in dem Skript keine Zeile die irgendwas mit "Watt" loggt. Bin ich blind?

Grüße

Dennis

P.S. nur weil da "Nachbooster Ein/Aus" oder /23h" als Kommentar steht, macht dass den Code nicht besser lesbar. Die Infos bringen mir z.B. nichts. Ordentliche, sprechende Namen würden weiterhelfen. 'timewindow1' etc. sagen so viel, wie wenn du das Objekt "blau_gruener_elefant' nennen würdest.

keepfear · Nov 11th 2022

Ich sehe da ehrlich gesagt auch kein Watt.

Da gibts nur

Python

# Raumtemperatur auslesen (Wohnzimmer west / Controme)
logging.info("Temp: %.2f", raum ["sensoren"][1]["wert"])

und

Python

# Shel1y WP_Verbrauch auslesen
logging.info('WP StartStartStartStartStart') # Logeintra

Warum auch immer da x-mal start steht.

Quote from gwaag

Ich bin kein Programmierer und das was ich hier programmiere kommt von dem was ich früher mit SPS programmiert habe, anders istt es für mich ja noch komplizierter

Das ist ja auch nicht bös gemeint. Ich denke aber das du doch langsam wissen müsstest wie man Funktionen nutzt.

gwaag · Nov 11th 2022

Dennis89

Du hast recht, in diesem scrip steht nicht von Watt die geloggt werden sollten, das kommt von einem anderen script das aber genau gleich aufgebaut ist.

Nachtbooster, wenn die Bedingung erfüllt ist, schaltet es die Waermepumpe über das SG-Ready signal etwas höher.

23h = bis 23.00h

timewindow1-6 = Zeitfenster wo abgefragt werden soll ( Anfang/Ende).

keepfear

WP-StartStartStartStartSart habe ich nur so gewählt damit es im log hinten heraussteht und ich es schneller finde, sollt ja nur alle 3-4h mal eintreten.

Hier noch das script mit dem Watt logging

Python

#!/usr/bin/env python3

import logging
import locale
import json
import requests
import subprocess
import time
from time import sleep




while True:
    sleep(30)

    locale.setlocale(locale.LC_ALL, 'de_DE.utf8')
    logging.basicConfig(filename='/home/pi/th/ms.log', format='%(asctime)s %(message)s', datefmt="Woche %V %a %d.%m.%Y %H:%M:%S",
    level=logging.INFO)


# Shel1y WP_Verbrauch auslesen

    response = requests.get("http://192.168.0.140/status")

    obj = response.json()


    print (obj ["emeters"][0]["power"])

    logging.info("Watt: %.2f", obj ["emeters"][0]["power"])   # Logeintrag

    low = obj ["emeters"][0]["power"]<= 20.0
    high = obj ["emeters"][0]["power"]>= 400

# Licht high/low schalten

    if low:
        subprocess.run ("/home/pi/th/WP-Licht_low.py")
    if high:
        subprocess.run ("/home/pi/th/WP-Licht_high.py")

# E-Mail senden

    if obj ["emeters"][0]["power"]<= 4.0:
        subprocess.run ("/home/pi/th/Mail_WP_Aus.py")

Display More