Schlagwort: homeassistant

Ein Upgrade für den Homeserver Teil 11 – Homeassistant

1. Januar 2024 / jjk1 / Keine Kommentare

Seit gut drei Jahren betreibe ich einen RaspberryPi als Homeserver. Zunächst reichte dieser noch gut aus. Mit der Zeit wurde aber nicht nur die Zahl der Anwendungen, die auf dem Raspberry laufen, mehr, sondern auch die Leistungsanforderungen der Anwendungen selbst. Besonders meine ich damit die Influx Datenbank, die seit über drei Jahren jede Minuten um einen Datensatz der PV-Anlage größer wird. Die Datenbank braucht mittlerweile über 10 Minuten zum Starten. Auch diese Webseite braucht zum Laden deutlich länger, als sie sollte. Wenn ich den Raspberry komplett neu starte, braucht es ca. eine Stunde, bis alle Anwendungen wieder laufen. Das ist definitiv zu viel. Es sollte also ein neuer Rechner her. In dieser Artikelserie möchte ich davon berichten.

Übersicht aller Artikel dieser Serie

Was ist Homeassistant?

Homeassistant ist eine Software zur Steuerung, Visualisierung und Automatisierung eines Smarthomes. In Homeassistant lassen sich Produkte von über 2500 Marken einbinden. Diese kann man dann zentral steuern oder automatisieren.

Installationsmethoden von Homeassistant

Grundlegend gibt es 3 Möglichkeiten, Homeassistant zu installieren: als „Homeassistant OS“, im Docker-Container oder direkt.

Homeassistant OS ist, wie der Name schon sagt, ein ganzes OS, also ein Linux-System mit Homeassistant (das übrigens auch hier in Docker installiert ist), Docker und einer vereinfachten Oberfläche, um weitere Docker-Container zu installieren. Praktisch Portainer nur sehr abgespeckt und mit begrenzter Auswahl an Containern. Die Vorteile dieser Installationsmethode sind, dass sie recht einfach ist und man auch als Anfänger recht leicht weitere Software installieren kann. Die Nachteile sind, dass man durch diese abgespeckte Software auch sehr beschränkt ist, vor allem, wenn man Homeassistant OS direkt installiert, da es eben ein ganzes OS ist und so keine weiteren Betriebssysteme parallel installiert werden können. Installiert man es aber in einer VM, zum Beispiel mit Proxmox, fällt dieser Nachteil natürlich weg. Aber auch dann braucht das Homeassistant OS minimal mehr Leistung als bei den anderen beiden Installationsmethoden.

Homeassistant im Docker-Container hat im Gegensatz zu Homeassistant OS eben nicht diese einfache Möglichkeit, andere Software zu installieren. Auch die Installation ist etwas komplizierter. Dafür hat man aber die volle Freiheit in der Wahl des Betriebssystems, unter dem Docker läuft und damit auch mehr Auswahl an Software.

Die direkte Installation von „Homeassistant core“ benötigt kein Docker. Der Funktionsumfang ist aber identisch zur Dockerinstallation. Der große Nachteil hier ist aber, dass die Installation mit Abstand am schwierigsten ist, da man sich hier mit verschiedenen Python-Versionen und Modulen herumschlagen muss.

Eine Übersicht der Installationsmethoden findet man hier.

Installation von Homeassistant

Ich habe mich für die Dockerinstallation entschieden. Dazu lege ich in Portainer einen neuen Container an. Diesen nenne ich „homeassistant“ und wähle im „Advanced mode“ das Image „ghcr.io/home-assistant/home-assistant:stable“.

Im Menü „Network“ wähle ich die Methode „host“.

Anschließend lege ich unter „env“ eine neue Umgebungsvariable für die Zeitzone an:

Dann aktiviere ich unter „Runtime & Resources“ den Priviledged Mode.

Als Letztes erstelle ich noch zwei Bind-Volumes. Beim ersten musst du den Pfad im Host bei deiner Installation anpassen. Beim zweiten ist es wichtig, dass er Read-Only gemountet ist.

Jetzt lässt sich der Container erstellen und anschließend die Weboberfläche von Homeassistant unter https://IP_ADRESSE:8123 öffnen.

Einrichten von Homeassistant

Dort begrüßt uns auch schon der Einrichtungsassistent:

Im ersten Schritt legt man einen Adminaccount an:

Anschließend legt man seine Heimatadresse fest, die zum Beispiel für die Wettervorhersage oder für Geofencing verwendet wird.

Für die Einheiten muss noch das Land festgelegt werden.

Möchte man anonyme Diagnosedaten an die Entwickler senden, kann man das im nächsten Schritt aktivieren:

Homeassistant sucht automatisch nach Geräten im Heimnetzwerk. Möchte man diese bereits bei der Einrichtung hinzufügen, kann man das mit einem Klick auf das jeweilige Gerät tun.

Installation von HACS

Homeassistant selbst bietet schon extrem viele Erweiterungen an. Noch mehr bekommt man mit dem „Home Assistant Community Store“ kurz HACS. Hier gibt es auch Erweiterungen für das Dashboard, zum Beispiel ein Wetterradar oder eine Erweiterung, um das Design des Dashboards per CSS zu ändern.

Um HACS zu installieren, geht man ins Terminal und wechselt in das Konfigurationsverzeichnis von Homeassistant. Das ist das Verzeichnis, wo auch unter anderem die Datei „configuration.yaml“ liegt.

Dort gibt man folgenden Befehl ein:

wget -O - https://get.hacs.xyz | bash -

1	wget -O - https://get.hacs.xyz \| bash -

Anschließend startet man Homeassistant neu, indem man unten links die Entwicklerwerkzeuge öffnet und dort auf „Neu starten“ klickt:

Dann kann man unter Einstellungen → Geräte und Dienste → Integration hinzufügen HACS hinzufügen.

Nachdem man die Integration HACS gewählt hat, muss man noch einige Punkte bestätigen. Ich wähle alle außer den letzten. Anschließend muss man noch HACS mit seinem GitHub Account verbinden. Das ist nötig, da die Erweiterungen aus HACS von GitHub heruntergeladen werden.

Hat man alles fertig eingerichtet, findet man HACS im Menü von Homeassistant und hat nun noch viel mehr Möglichkeiten, Geräte einzubinden und sein Dashboard zu gestalten.

Waveshare Modbus Relais in Homeassistant

17. Juni 2023 / jjk1 / Keine Kommentare

In diesem Beitrag möchte ich dir zeigen, wie ich ein 8-fach Modbus Relais von Waveshare in Homeassistant eingebunden habe.

Material

Aufbau

Der Aufbau ist nicht kompliziert. Die Anschlüsse A+, B- und GND müssen mit den entsprechend gleichnamigen Anschlüssen am Relais verbunden werden. Dann ist nur noch eine Spannungsversorgung für das Relais notwendig und man kann loslegen.

Mitgelieferte Software

Im Waveshare Wiki findet man neben zahlreichen Beispielen auch einen Beispielcode in Python. Dieser sendet die Daten direkt über „serial“ an das Modbus Relais und zur Berechnung der Paritätsbytes wird ebenfalls ein eigenes Pythonmodul mitgeliefert. Das ist etwas umständlich, da es für Modbus bereits fertige Pythonmodule wie minimalmodbus gibt.

Steuerung mit Minimalmodbus

Nach der Installation mit

pip3 install minimalmodbus

1	pip3 install minimalmodbus

kann das Modul verwendet werden. Folgendes wäre ein Beispielcode:

import minimalmodbus

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)
modbusrelay_heizung.serial.timeout  = 0.1

def set_relais(relay, state):
    if state == "on":
        modbusrelay_heizung.write_bit(int(relay)-1, 1)
    if state == "off":
        modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():
    binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)
    print("Relais:" + str(binary_relais))

import minimalmodbus

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)

modbusrelay_heizung.serial.timeout = 0.1

def set_relais(relay, state):

if state == "on":

modbusrelay_heizung.write_bit(int(relay)-1, 1)

if state == "off":

modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():

binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)

print("Relais:" + str(binary_relais))

In Zeile 3 wird der Pfad zum USB -> Modbus Konverter und die ID des Relais angegeben. Die ID wird in den meisten Fällen 1 sein. Bei mir habe ich sie aber geändert, da am selben Modbus auch ein Stromzähler hängt, der die ID 1 bekommen hat. Mit den Funktionen get_relais() und set_relais(relais, on/off) kann man jetzt die Relais schalten und deren Status abfragen.

Einbindung in Homeassistant

Um das Modbus Relais in Homeassistant einzubinden, verwende ich MQTT. Dieses sollte bereits installiert und eingebunden sein. Mein Code sieht dann folgendermaßen aus:

#!/usr/bin/env python3

import paho.mqtt.client as mqtt
import requests
import time
import minimalmodbus

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)
modbusrelay_heizung.serial.timeout  = 0.1
print(modbusrelay_heizung)

def set_relais(relay, state):
    if state == "on":
        modbusrelay_heizung.write_bit(int(relay)-1, 1)
    if state == "off":
        modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():
    binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)
    print("Relais:" + str(binary_relais))
    for i in range(8):
        if binary_relais[i] == 1:
            client.publish("modbus/relais_heizung/get/" + str(i+1), "on")
        else:
            client.publish("modbus/relais_heizung/get/" + str(i+1), "off")

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("modbus/relais_heizung/set/#")

def on_message(client, userdata, msg):
    splitted_topic = msg.topic.split("/")
    relay = splitted_topic[3]
    print("Relay " + relay + " " + msg.payload.decode())
    ready = False
    while not(ready):
        set_relais(relay, msg.payload.decode())
        time.sleep(0.1)
        get_relais()
        ready = True
  
client = mqtt.Client()
client.connect("localhost",1883,60)
client.on_connect = on_connect
client.on_message = on_message
get_relais()
client.loop_forever()

#!/usr/bin/env python3

import paho.mqtt.client as mqtt

import requests

import time

import minimalmodbus

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)

modbusrelay_heizung.serial.timeout = 0.1

print(modbusrelay_heizung)

def set_relais(relay, state):

if state == "on":

modbusrelay_heizung.write_bit(int(relay)-1, 1)

if state == "off":

modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():

binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)

print("Relais:" + str(binary_relais))

for i in range(8):

if binary_relais[i] == 1:

client.publish("modbus/relais_heizung/get/" + str(i+1), "on")

else:

client.publish("modbus/relais_heizung/get/" + str(i+1), "off")

def on_connect(client, userdata, flags, rc):

print("Connected with result code "+str(rc))

client.subscribe("modbus/relais_heizung/set/#")

def on_message(client, userdata, msg):

splitted_topic = msg.topic.split("/")

relay = splitted_topic[3]

print("Relay " + relay + " " + msg.payload.decode())

ready = False

while not(ready):

set_relais(relay, msg.payload.decode())

time.sleep(0.1)

get_relais()

ready = True

client = mqtt.Client()

client.connect("localhost",1883,60)

client.on_connect = on_connect

client.on_message = on_message

get_relais()

client.loop_forever()

Hinzu kommt jetzt die Anbindung an MQTT. Wichtig ist dabei

Z. 8: Siehe oben
S. 23+25: Hier werden die Statuswerte der Relais an MQTT gesendet
Z. 29: Hier wird das MQTT Topic subscribed, an das nachher die Befehle zum setzen gesendet werden
Z. 43: Hier findet die Verbindung zum MQTT Broker statt

In Homeassistant verwende ich nun folgende Konfiguration:

switch:
  - unique_id: modbus_relais_heizung_1
    name: "Modbus Relais Heizung 1"
    state_topic: "modbus/relais_heizung/get/1"
    command_topic: "modbus/relais_heizung/set/1"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_2
    name: "Modbus Relais Heizung 2"
    state_topic: "modbus/relais_heizung/get/2"
    command_topic: "modbus/relais_heizung/set/2"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_3
    name: "Modbus Relais Heizung 3"
    state_topic: "modbus/relais_heizung/get/3"
    command_topic: "modbus/relais_heizung/set/3"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_4
    name: "Modbus Relais Heizung 4"
    state_topic: "modbus/relais_heizung/get/4"
    command_topic: "modbus/relais_heizung/set/4"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_5
    name: "Modbus Relais Heizung 5"
    state_topic: "modbus/relais_heizung/get/5"
    command_topic: "modbus/relais_heizung/set/5"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_6
    name: "Modbus Relais Heizung 6"
    state_topic: "modbus/relais_heizung/get/6"
    command_topic: "modbus/relais_heizung/set/6"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_7
    name: "Modbus Relais Heizung 7"
    state_topic: "modbus/relais_heizung/get/7"
    command_topic: "modbus/relais_heizung/set/7"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0
  - unique_id: modbus_relais_heizung_8
    name: "Modbus Relais Heizung 8"
    state_topic: "modbus/relais_heizung/get/8"
    command_topic: "modbus/relais_heizung/set/8"
    payload_on: "on"
    payload_off: "off"
    state_on: "on"
    state_off: "off"
    qos: 0

switch:

- unique_id: modbus_relais_heizung_1

state_topic: "modbus/relais_heizung/get/1"

command_topic: "modbus/relais_heizung/set/1"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_2

state_topic: "modbus/relais_heizung/get/2"

command_topic: "modbus/relais_heizung/set/2"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_3

state_topic: "modbus/relais_heizung/get/3"

command_topic: "modbus/relais_heizung/set/3"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_4

state_topic: "modbus/relais_heizung/get/4"

command_topic: "modbus/relais_heizung/set/4"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_5

state_topic: "modbus/relais_heizung/get/5"

command_topic: "modbus/relais_heizung/set/5"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_6

state_topic: "modbus/relais_heizung/get/6"

command_topic: "modbus/relais_heizung/set/6"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_7

state_topic: "modbus/relais_heizung/get/7"

command_topic: "modbus/relais_heizung/set/7"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

- unique_id: modbus_relais_heizung_8

state_topic: "modbus/relais_heizung/get/8"

command_topic: "modbus/relais_heizung/set/8"

payload_on: "on"

payload_off: "off"

state_on: "on"

state_off: "off"

qos: 0

Jetzt kann ich die Relais auch in Homeassistant schalten. Dabei muss das Pythonskript dauerhaft laufen, was man bspw. mit einer systemd Service Unit erreicht.

Gleichzeitig Modbus Relais und Stromzähler auslesen

Da ich, wie bereits erwähnt, einen Stromzähler und Relais an einem Modbus hängen habe und immer nur ein Programm auf den Modbus zugreifen kann, muss ich im selben Skript auch den Stromzähler auslesen. Das Skript dazu sieht so aus:

#!/usr/bin/env python3

import paho.mqtt.client as mqtt
import requests
import time
import minimalmodbus
import influxdb

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)
modbusrelay_heizung.serial.timeout  = 0.1
print(modbusrelay_heizung)
influxclient = influxdb.InfluxDBClient(host="serverpi", port=8086, database="energy")

relais_freigabe = True

def set_relais(relay, state):
    if state == "on":
        modbusrelay_heizung.write_bit(int(relay)-1, 1)
    if state == "off":
        modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():
    binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)
    print("Relais:" + str(binary_relais))
    for i in range(8):
        if binary_relais[i] == 1:
            client.publish("modbus/relais_heizung/get/" + str(i+1), "on")
        else:
            client.publish("modbus/relais_heizung/get/" + str(i+1), "off")

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe("modbus/relais_heizung/set/#")

def on_message(client, userdata, msg):
    splitted_topic = msg.topic.split("/")
    relay = splitted_topic[3]
    print("Relay " + relay + " " + msg.payload.decode())
    ready = False
    while not(ready):
        if relais_freigabe:
            set_relais(relay, msg.payload.decode())
            time.sleep(0.1)
            get_relais()
            ready = True
        else:
            print("Warte 1 sek")
            time.sleep(1)
    

client = mqtt.Client()
client.connect("localhost",1883,60)
client.on_connect = on_connect
client.on_message = on_message
get_relais()
client.loop_start()
while True:
    try:
        time.sleep(0.1)
        time1 = time.perf_counter()
        # ------------------ Modbus Heizung ------------------
        modbus_instrument = "/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0"
        name = "heizung"
        # ------------------
        # try:
        modbuszaehler = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 1, debug = True)
        modbuszaehler.serial.timeout = 1.0
        print(modbuszaehler)
        input_register = {
            "Spannung_L1": {
                "port": 0, "digits": 2, "Unit": "V", "use": True},
            "Spannung_L2": {
                "port": 2, "digits": 2, "Unit": "V", "use": True},
            "Spannung_L3": {
                "port": 4, "digits": 2, "Unit": "V", "use": True},
            "Strom_L1": {
                "port": 6, "digits": 2, "Unit": "A", "use": True},
            "Strom_L2": {
                "port": 8, "digits": 2, "Unit": "A", "use": True},
            "Strom_L3": {
                "port": 10, "digits": 2, "Unit": "A", "use": True},
            "Wirkleistung_L1": {
                "port": 12, "digits": 2, "Unit": "W", "use": True},
            "Wirkleistung_L2": {
                "port": 14, "digits": 2, "Unit": "W", "use": True},
            "Wirkleistung_L3": {
                "port": 16, "digits": 2, "Unit": "W", "use": True},
            "Scheinleistung_L1": {
                "port": 18, "digits": 2, "Unit": "VA", "use": True},
            "Scheinleistung_L2": {
                "port": 20, "digits": 2, "Unit": "VA", "use": True},
            "Scheinleistung_L3": {
                "port": 22, "digits": 2, "Unit": "VA", "use": True},
            "Blindleistung_L1": {
                "port": 24, "digits": 2, "Unit": "VAr", "use": True},
            "Blindleistung_L2": {
                "port": 26, "digits": 2, "Unit": "VAr", "use": True},
            "Blindleistung_L3": {
                "port": 28, "digits": 2, "Unit": "VAr", "use": True},
            "Leistungsfaktor_L1": {
                "port": 30, "digits": 2, "Unit": "", "use": True},
            "Leistungsfaktor_L2": {
                "port": 32, "digits": 2, "Unit": "", "use": True},
            "Leistungsfaktor_L3": {
                "port": 34, "digits": 2, "Unit": "", "use": True},
            "Phasenwinkel_L1": {
                "port": 36, "digits": 2, "Unit": "Grad", "use": True},
            "Phasenwinkel_L2": {
                "port": 38, "digits": 2, "Unit": "Grad", "use": True},
            "Phasenwinkel_L3": {
                "port": 40, "digits": 2, "Unit": "Grad", "use": True},
            "Durchschnittliche_Spannung_zu_N": {
                "port": 42, "digits": 2, "Unit": "V", "use": True},
            "Durchschnittlicher_Strom_zu_N": {
                "port": 46, "digits": 2, "Unit": "A", "use": True},
            "aktueller_Gesamtstrom": {
                "port": 48, "digits": 2, "Unit": "A", "use": True},
            "aktuelle_Gesamtwirkleistung": {
                "port": 52, "digits": 2, "Unit": "W", "use": True},
            "aktuelle_Gesamtscheinleistung": {
                "port": 56, "digits": 2, "Unit": "VA", "use": True},
            "aktuelle_Gesamtblindleistung": {
                "port": 60, "digits": 2, "Unit": "VAr", "use": True},
            "aktueller_Gesamtleistungsfaktor": {
                "port": 62, "digits": 2, "Unit": "", "use": True},
            "aktueller_Gesamtphasenwinkel": {
                "port": 66, "digits": 2, "Unit": "A", "use": True},
            "Frequenz": {
                "port": 70, "digits": 2, "Unit": "Hz", "use": True},
            "Import_Wh_seit_reset": {
                "port": 72, "digits": 2, "Unit": "kWh", "use": True},
            "Export_Wh_seit_reset": {
                "port": 74, "digits": 2, "Unit": "kWH", "use": True},
            "Import_VArh_seit_reset": {
                "port": 76, "digits": 2, "Unit": "kVArh", "use": True},
            "Export_VArh_seit_reset": {
                "port": 78, "digits": 2, "Unit": "kVArh", "use": True},
            "VAh_seit_reset": {
                "port": 80, "digits": 2, "Unit": "kVAh", "use": True},
            "Ah_seit_reset": {
                "port": 82, "digits": 2, "Unit": "Ah", "use": True},
            "Gesamtwirkleistung": {
                "port": 84, "digits": 2, "Unit": "W", "use": True},
            "Max_Gesamtwirkleistung": {
                "port": 86, "digits": 2, "Unit": "W", "use": True},
            "Gesamtscheinleistung": {
                "port": 100, "digits": 2, "Unit": "VA", "use": True},
            "Max_Gesamtscheinleistung": {
                "port": 102, "digits": 2, "Unit": "VA", "use": True},
            "Gesamtstrom_Neutralleiter": {
                "port": 104, "digits": 2, "Unit": "A", "use": True},
            "Max_Strom_Neutralleiter": {
                "port": 106, "digits": 2, "Unit": "A", "use": True},
            "Spannung_L1_L2": {
                "port": 200, "digits": 2, "Unit": "V", "use": True},
            "Spannung_L2_L3": {
                "port": 202, "digits": 2, "Unit": "V", "use": True},
            "Spannung_L3_L1": {
                "port": 204, "digits": 2, "Unit": "V", "use": True},
            "Durchschnittsspannung_L_L": {
                "port": 206, "digits": 2, "Unit": "V", "use": True},
            "Strom_Neutralleiter": {
                "port": 224, "digits": 2, "Unit": "A", "use": True},
            "THD_Spannung_L1": {
                "port": 234, "digits": 2, "Unit": "%", "use": True},
            "THD_Spannung_L2": {
                "port": 236, "digits": 2, "Unit": "%", "use": True},
            "THD_Spannung_L3": {
                "port": 238, "digits": 2, "Unit": "%", "use": True},
            "THD_Strom_L1": {
                "port": 240, "digits": 2, "Unit": "%", "use": True},
            "THD_Strom_L2": {
                "port": 242, "digits": 2, "Unit": "%", "use": True},
            "THD_Strom_L3": {
                "port": 244, "digits": 2, "Unit": "%", "use": True},
            "THD_Durchschnittliche_Spannung_zu_N": {
                "port": 248, "digits": 2, "Unit": "%", "use": True},
            "THD_Durchschnittlicher_Strom_zu_N": {
                "port": 250, "digits": 2, "Unit": "%", "use": True},
            "Strom_L1_demand": {
                "port": 258, "digits": 2, "Unit": "A", "use": True},
            "Strom_L2_demand": {
                "port": 260, "digits": 2, "Unit": "A", "use": True},
            "Strom_L3_demand": {
                "port": 262, "digits": 2, "Unit": "A", "use": True},
            "Max_Strom_L1_demand": {
                "port": 264, "digits": 2, "Unit": "A", "use": True},
            "Max_Strom_L2_demand": {
                "port": 266, "digits": 2, "Unit": "A", "use": True},
            "Max_Strom_L3_demand": {
                "port": 268, "digits": 2, "Unit": "A", "use": True},
            "THD_Spannung_L1_L2": {
                "port": 334, "digits": 2, "Unit": "%", "use": True},
            "THD_Spannung_L2_L3": {
                "port": 336, "digits": 2, "Unit": "%", "use": True},
            "THD_Spannung_L3_L1": {
                "port": 338, "digits": 2, "Unit": "%", "use": True},
            "THD_Durchschnittliche_Spannung_zu_L_L": {
                "port": 340, "digits": 2, "Unit": "%", "use": True},
            "Total_kwh": {
                "port": 342, "digits": 2, "Unit": "kwh", "use": True},
            "Total_kvarh": {
                "port": 344, "digits": 2, "Unit": "kvarh", "use": True},
            "Import_L1_kwh": {
                "port": 346, "digits": 2, "Unit": "kwh", "use": True},
            "Import_L2_kwh": {
                "port": 348, "digits": 2, "Unit": "kwh", "use": True},
            "Import_L3_kwh": {
                "port": 350, "digits": 2, "Unit": "kwh", "use": True},
            "Export_L1_kwh": {
                "port": 352, "digits": 2, "Unit": "kwh", "use": True},
            "Export_L2_kwh": {
                "port": 354, "digits": 2, "Unit": "kwh", "use": True},
            "Export_L3_kwh": {
                "port": 356, "digits": 2, "Unit": "kwh", "use": True},
            "Gesamtstrom_L1_kwh": {
                "port": 358, "digits": 2, "Unit": "kwh", "use": True},
            "Gesamtstrom_L2_kwh": {
                "port": 360, "digits": 2, "Unit": "kwh", "use": True},
            "Gesamtstrom_L3_kwh": {
                "port": 362, "digits": 2, "Unit": "kwh", "use": True},
            "Import_L1_kvarh": {
                "port": 364, "digits": 2, "Unit": "kvarh", "use": True},
            "Import_L2_kvarh": {
                "port": 366, "digits": 2, "Unit": "kvarh", "use": True},
            "Import_L3_kvarh": {
                "port": 368, "digits": 2, "Unit": "kvarh", "use": True},
            "Export_L1_kvarh": {
                "port": 370, "digits": 2, "Unit": "kvarh", "use": True},
            "Export_L2_kvarh": {
                "port": 372, "digits": 2, "Unit": "kvarh", "use": True},
            "Export_L3_kvarh": {
                "port": 374, "digits": 2, "Unit": "kvarh", "use": True},
            "Total_L1_kvarh": {
                "port": 376, "digits": 2, "Unit": "kvarh", "use": True},
            "Total_L2_kvarh": {
                "port": 378, "digits": 2, "Unit": "kvarh", "use": True},
            "Total_L3_kvarh": {
                "port": 380, "digits": 2, "Unit": "kvarh", "use": True},
        }
        heizung_json_body = [
            {
                "measurement": name,
                "fields": {}
            },
        ]
        relais_freigabe = False
        for key in input_register:
            if input_register[key]["use"] == True:
                heizung_json_body[0]["fields"][key] = round(modbuszaehler.read_float(functioncode=4, registeraddress=input_register[key]["port"], number_of_registers=input_register[key]["digits"]), 2)
        relais_freigabe = True
        # ------------------ Tasmota Haus ------------------
        tasmota_url = "http://tasmota-1ae72e-1838.fritz.box"
        name = "tasmota_haus"
        # ------------------
        try:
            r = requests.get(tasmota_url + "/cm?cmnd=status%2010")
            json = r.json()
            tasmota_values = {}
            tasmota_haus_json_body = [
                {
                    "measurement": name,
                    "fields": {}
                },
            ]

            for key in json["StatusSNS"]["MT175"]:
                try:
                    tasmota_values[key] = float(json["StatusSNS"]["MT175"][key])
                except:
                    tasmota_values[key] = str(json["StatusSNS"]["MT175"][key])
                    
            tasmota_haus_json_body[0]['fields']['Leistung'] = tasmota_values['Power_curr']
            tasmota_haus_json_body[0]['fields']['Import_kWh'] = tasmota_values['Total']
            tasmota_haus_json_body[0]['fields']['Export_kWh'] = tasmota_values['Total_out']
            #print(tasmota_haus_json_body)
        except:
            print("Fehler beim Lesen von Tasmota Haus")

        # ------------------ Tasmota Heizung ------------------
        tasmota_url = "http://tasmota-1ae72e-1838.fritz.box"
        name = "tasmota_heizung"
        # ------------------
        try:
            r = requests.get(tasmota_url + "/cm?cmnd=status%2010")
            json = r.json()
            tasmota_values = {}
            tasmota_heizung_json_body = [
                {
                    "measurement": name,
                    "fields": {}
                },
            ]

            for key in json["StatusSNS"]["METER1"]:
                try:
                    tasmota_values[key] = float(json["StatusSNS"]["METER1"][key])
                except:
                    tasmota_values[key] = str(json["StatusSNS"]["METER1"][key])
            
            tasmota_heizung_json_body[0]['fields']['Leistung'] = tasmota_values['Power_curr']
            tasmota_heizung_json_body[0]['fields']['Import_kWh'] = tasmota_values['Total']
            tasmota_heizung_json_body[0]['fields']['Export_kWh'] = tasmota_values['Total_out']
            #print(tasmota_heizung_json_body)
        except:
            print("Fehler beim Lesen von Tasmota Haus")
        # ------------------ Heizungsleistung berechnen ------------------
        try:
            heizung_json_body[0]['fields']['Leistung'] = tasmota_heizung_json_body[0]['fields']['Leistung']-tasmota_haus_json_body[0]['fields']['Leistung'] + heizung_json_body[0]['fields']['aktuelle_Gesamtwirkleistung']
            if(tasmota_heizung_json_body[0]['fields']['Leistung']>=0 and tasmota_haus_json_body[0]['fields']['Leistung']>=0): # Voll Netzbetrieb
                heizung_json_body[0]['fields']['Leistung_Netz'] = heizung_json_body[0]['fields']['Leistung']
                heizung_json_body[0]['fields']['Leistung_PV'] = 0.0
                
            elif(tasmota_heizung_json_body[0]['fields']['Leistung']<=0 and tasmota_haus_json_body[0]['fields']['Leistung']<=0): # PV Betrieb
                heizung_json_body[0]['fields']['Leistung_Netz'] = 0.0
                heizung_json_body[0]['fields']['Leistung_PV'] = heizung_json_body[0]['fields']['Leistung']

            else: #Mischung
                heizung_json_body[0]['fields']['Leistung_Netz'] = tasmota_heizung_json_body[0]['fields']['Leistung']
                heizung_json_body[0]['fields']['Leistung_PV'] = tasmota_haus_json_body[0]['fields']['Leistung']*-1
                # Modbus Leistung dazurechnen
            heizung_json_body[0]['fields']['Leistung_Modbus'] = heizung_json_body[0]['fields']['aktuelle_Gesamtwirkleistung']
        except:
            print("Fehler beim Berechnen von Heizungsleistung")

        # ------------------ Zählerstand Heizung berechnen ------------------
        heizung_json_body[0]['fields']['Zaehlerstand_Einspeisung'] = tasmota_haus_json_body[0]['fields']['Export_kWh'] - tasmota_heizung_json_body[0]['fields']['Export_kWh']
        heizung_json_body[0]['fields']['Zaehlerstand_Bezug'] = tasmota_heizung_json_body[0]['fields']['Import_kWh'] - tasmota_haus_json_body[0]['fields']['Import_kWh']
        heizung_json_body[0]['fields']['Zaehlerstand_PV'] = heizung_json_body[0]["fields"]['Total_kwh']
        print(heizung_json_body)
        influxclient.write_points(heizung_json_body)
        # except:
        #     print("Fehler beim Lesen von Modbuszähler Heizung")
        time2 = time.perf_counter()
        timedifference = time2-time1
        if timedifference < 60:
            time.sleep(60-timedifference)
    except:
        print("Fehler beim Auslesen vom Modbuszähler")
        time.sleep(60)

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

#!/usr/bin/env python3

import paho.mqtt.client as mqtt

import requests

import time

import minimalmodbus

import influxdb

modbusrelay_heizung = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 2, debug = True)

modbusrelay_heizung.serial.timeout = 0.1

print(modbusrelay_heizung)

influxclient = influxdb.InfluxDBClient(host="serverpi", port=8086, database="energy")

relais_freigabe = True

def set_relais(relay, state):

if state == "on":

modbusrelay_heizung.write_bit(int(relay)-1, 1)

if state == "off":

modbusrelay_heizung.write_bit(int(relay)-1, 0)

def get_relais():

binary_relais = modbusrelay_heizung.read_bits(0, 8, 1)

print("Relais:" + str(binary_relais))

for i in range(8):

if binary_relais[i] == 1:

client.publish("modbus/relais_heizung/get/" + str(i+1), "on")

else:

client.publish("modbus/relais_heizung/get/" + str(i+1), "off")

def on_connect(client, userdata, flags, rc):

print("Connected with result code "+str(rc))

client.subscribe("modbus/relais_heizung/set/#")

def on_message(client, userdata, msg):

splitted_topic = msg.topic.split("/")

relay = splitted_topic[3]

print("Relay " + relay + " " + msg.payload.decode())

ready = False

while not(ready):

if relais_freigabe:

set_relais(relay, msg.payload.decode())

time.sleep(0.1)

get_relais()

ready = True

else:

print("Warte 1 sek")

time.sleep(1)

client = mqtt.Client()

client.connect("localhost",1883,60)

client.on_connect = on_connect

client.on_message = on_message

get_relais()

client.loop_start()

while True:

try:

time.sleep(0.1)

time1 = time.perf_counter()

# ------------------ Modbus Heizung ------------------

modbus_instrument = "/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0"

name = "heizung"

# ------------------

# try:

modbuszaehler = minimalmodbus.Instrument('/dev/serial/by-id/usb-1a86_USB_Serial-if00-port0', 1, debug = True)

modbuszaehler.serial.timeout = 1.0

print(modbuszaehler)

input_register = {

"Spannung_L1": {

"port": 0, "digits": 2, "Unit": "V", "use": True},

"Spannung_L2": {

"port": 2, "digits": 2, "Unit": "V", "use": True},

"Spannung_L3": {

"port": 4, "digits": 2, "Unit": "V", "use": True},

"Strom_L1": {

"port": 6, "digits": 2, "Unit": "A", "use": True},

"Strom_L2": {

"port": 8, "digits": 2, "Unit": "A", "use": True},

"Strom_L3": {

"port": 10, "digits": 2, "Unit": "A", "use": True},

"Wirkleistung_L1": {

"port": 12, "digits": 2, "Unit": "W", "use": True},

"Wirkleistung_L2": {

"port": 14, "digits": 2, "Unit": "W", "use": True},

"Wirkleistung_L3": {

"port": 16, "digits": 2, "Unit": "W", "use": True},

"Scheinleistung_L1": {

"port": 18, "digits": 2, "Unit": "VA", "use": True},

"Scheinleistung_L2": {

"port": 20, "digits": 2, "Unit": "VA", "use": True},

"Scheinleistung_L3": {

"port": 22, "digits": 2, "Unit": "VA", "use": True},

"Blindleistung_L1": {

"port": 24, "digits": 2, "Unit": "VAr", "use": True},

"Blindleistung_L2": {

"port": 26, "digits": 2, "Unit": "VAr", "use": True},

"Blindleistung_L3": {

"port": 28, "digits": 2, "Unit": "VAr", "use": True},

"Leistungsfaktor_L1": {

"port": 30, "digits": 2, "Unit": "", "use": True},

"Leistungsfaktor_L2": {

"port": 32, "digits": 2, "Unit": "", "use": True},

"Leistungsfaktor_L3": {

"port": 34, "digits": 2, "Unit": "", "use": True},

"Phasenwinkel_L1": {

"port": 36, "digits": 2, "Unit": "Grad", "use": True},

"Phasenwinkel_L2": {

"port": 38, "digits": 2, "Unit": "Grad", "use": True},

"Phasenwinkel_L3": {

"port": 40, "digits": 2, "Unit": "Grad", "use": True},

"Durchschnittliche_Spannung_zu_N": {

"port": 42, "digits": 2, "Unit": "V", "use": True},

"Durchschnittlicher_Strom_zu_N": {

"port": 46, "digits": 2, "Unit": "A", "use": True},

"aktueller_Gesamtstrom": {

"port": 48, "digits": 2, "Unit": "A", "use": True},

"aktuelle_Gesamtwirkleistung": {

"port": 52, "digits": 2, "Unit": "W", "use": True},

"aktuelle_Gesamtscheinleistung": {

"port": 56, "digits": 2, "Unit": "VA", "use": True},

"aktuelle_Gesamtblindleistung": {

"port": 60, "digits": 2, "Unit": "VAr", "use": True},

"aktueller_Gesamtleistungsfaktor": {

"port": 62, "digits": 2, "Unit": "", "use": True},

"aktueller_Gesamtphasenwinkel": {

"port": 66, "digits": 2, "Unit": "A", "use": True},

"Frequenz": {

"port": 70, "digits": 2, "Unit": "Hz", "use": True},

"Import_Wh_seit_reset": {

"port": 72, "digits": 2, "Unit": "kWh", "use": True},

"Export_Wh_seit_reset": {

"port": 74, "digits": 2, "Unit": "kWH", "use": True},

"Import_VArh_seit_reset": {

"port": 76, "digits": 2, "Unit": "kVArh", "use": True},

"Export_VArh_seit_reset": {

"port": 78, "digits": 2, "Unit": "kVArh", "use": True},

"VAh_seit_reset": {

"port": 80, "digits": 2, "Unit": "kVAh", "use": True},

"Ah_seit_reset": {

"port": 82, "digits": 2, "Unit": "Ah", "use": True},

"Gesamtwirkleistung": {

"port": 84, "digits": 2, "Unit": "W", "use": True},

"Max_Gesamtwirkleistung": {

"port": 86, "digits": 2, "Unit": "W", "use": True},

"Gesamtscheinleistung": {

"port": 100, "digits": 2, "Unit": "VA", "use": True},

"Max_Gesamtscheinleistung": {

"port": 102, "digits": 2, "Unit": "VA", "use": True},

"Gesamtstrom_Neutralleiter": {

"port": 104, "digits": 2, "Unit": "A", "use": True},

"Max_Strom_Neutralleiter": {

"port": 106, "digits": 2, "Unit": "A", "use": True},

"Spannung_L1_L2": {

"port": 200, "digits": 2, "Unit": "V", "use": True},

"Spannung_L2_L3": {

"port": 202, "digits": 2, "Unit": "V", "use": True},

"Spannung_L3_L1": {

"port": 204, "digits": 2, "Unit": "V", "use": True},

"Durchschnittsspannung_L_L": {

"port": 206, "digits": 2, "Unit": "V", "use": True},

"Strom_Neutralleiter": {

"port": 224, "digits": 2, "Unit": "A", "use": True},

"THD_Spannung_L1": {

"port": 234, "digits": 2, "Unit": "%", "use": True},

"THD_Spannung_L2": {

"port": 236, "digits": 2, "Unit": "%", "use": True},

"THD_Spannung_L3": {

"port": 238, "digits": 2, "Unit": "%", "use": True},

"THD_Strom_L1": {

"port": 240, "digits": 2, "Unit": "%", "use": True},

"THD_Strom_L2": {

"port": 242, "digits": 2, "Unit": "%", "use": True},

"THD_Strom_L3": {

"port": 244, "digits": 2, "Unit": "%", "use": True},

"THD_Durchschnittliche_Spannung_zu_N": {

"port": 248, "digits": 2, "Unit": "%", "use": True},

"THD_Durchschnittlicher_Strom_zu_N": {

"port": 250, "digits": 2, "Unit": "%", "use": True},

"Strom_L1_demand": {

"port": 258, "digits": 2, "Unit": "A", "use": True},

"Strom_L2_demand": {

"port": 260, "digits": 2, "Unit": "A", "use": True},

"Strom_L3_demand": {

"port": 262, "digits": 2, "Unit": "A", "use": True},

"Max_Strom_L1_demand": {

"port": 264, "digits": 2, "Unit": "A", "use": True},

"Max_Strom_L2_demand": {

"port": 266, "digits": 2, "Unit": "A", "use": True},

"Max_Strom_L3_demand": {

"port": 268, "digits": 2, "Unit": "A", "use": True},

"THD_Spannung_L1_L2": {

"port": 334, "digits": 2, "Unit": "%", "use": True},

"THD_Spannung_L2_L3": {

"port": 336, "digits": 2, "Unit": "%", "use": True},

"THD_Spannung_L3_L1": {

"port": 338, "digits": 2, "Unit": "%", "use": True},

"THD_Durchschnittliche_Spannung_zu_L_L": {

"port": 340, "digits": 2, "Unit": "%", "use": True},

"Total_kwh": {

"port": 342, "digits": 2, "Unit": "kwh", "use": True},

"Total_kvarh": {

"port": 344, "digits": 2, "Unit": "kvarh", "use": True},

"Import_L1_kwh": {

"port": 346, "digits": 2, "Unit": "kwh", "use": True},

"Import_L2_kwh": {

"port": 348, "digits": 2, "Unit": "kwh", "use": True},

"Import_L3_kwh": {

"port": 350, "digits": 2, "Unit": "kwh", "use": True},

"Export_L1_kwh": {

"port": 352, "digits": 2, "Unit": "kwh", "use": True},

"Export_L2_kwh": {

"port": 354, "digits": 2, "Unit": "kwh", "use": True},

"Export_L3_kwh": {

"port": 356, "digits": 2, "Unit": "kwh", "use": True},

"Gesamtstrom_L1_kwh": {

"port": 358, "digits": 2, "Unit": "kwh", "use": True},

"Gesamtstrom_L2_kwh": {

"port": 360, "digits": 2, "Unit": "kwh", "use": True},

"Gesamtstrom_L3_kwh": {

"port": 362, "digits": 2, "Unit": "kwh", "use": True},

"Import_L1_kvarh": {

"port": 364, "digits": 2, "Unit": "kvarh", "use": True},

"Import_L2_kvarh": {

"port": 366, "digits": 2, "Unit": "kvarh", "use": True},

"Import_L3_kvarh": {

"port": 368, "digits": 2, "Unit": "kvarh", "use": True},

"Export_L1_kvarh": {

"port": 370, "digits": 2, "Unit": "kvarh", "use": True},

"Export_L2_kvarh": {

"port": 372, "digits": 2, "Unit": "kvarh", "use": True},

"Export_L3_kvarh": {

"port": 374, "digits": 2, "Unit": "kvarh", "use": True},

"Total_L1_kvarh": {

"port": 376, "digits": 2, "Unit": "kvarh", "use": True},

"Total_L2_kvarh": {

"port": 378, "digits": 2, "Unit": "kvarh", "use": True},

"Total_L3_kvarh": {

"port": 380, "digits": 2, "Unit": "kvarh", "use": True},

}

heizung_json_body = [

{

"measurement": name,

"fields": {}

]

relais_freigabe = False

for key in input_register:

if input_register[key]["use"] == True:

heizung_json_body[0]["fields"][key] = round(modbuszaehler.read_float(functioncode=4, registeraddress=input_register[key]["port"], number_of_registers=input_register[key]["digits"]), 2)

relais_freigabe = True

# ------------------ Tasmota Haus ------------------

tasmota_url = "http://tasmota-1ae72e-1838.fritz.box"

name = "tasmota_haus"

# ------------------

try:

r = requests.get(tasmota_url + "/cm?cmnd=status%2010")

json = r.json()

tasmota_values = {}

tasmota_haus_json_body = [

{

"measurement": name,

"fields": {}

]

for key in json["StatusSNS"]["MT175"]:

try:

tasmota_values[key] = float(json["StatusSNS"]["MT175"][key])

except:

tasmota_values[key] = str(json["StatusSNS"]["MT175"][key])

tasmota_haus_json_body[0]['fields']['Leistung'] = tasmota_values['Power_curr']

tasmota_haus_json_body[0]['fields']['Import_kWh'] = tasmota_values['Total']

tasmota_haus_json_body[0]['fields']['Export_kWh'] = tasmota_values['Total_out']

#print(tasmota_haus_json_body)

except:

print("Fehler beim Lesen von Tasmota Haus")

# ------------------ Tasmota Heizung ------------------

tasmota_url = "http://tasmota-1ae72e-1838.fritz.box"

name = "tasmota_heizung"

# ------------------

try:

r = requests.get(tasmota_url + "/cm?cmnd=status%2010")

json = r.json()

tasmota_values = {}

tasmota_heizung_json_body = [

{

"measurement": name,

"fields": {}

]

for key in json["StatusSNS"]["METER1"]:

try:

tasmota_values[key] = float(json["StatusSNS"]["METER1"][key])

except:

tasmota_values[key] = str(json["StatusSNS"]["METER1"][key])

tasmota_heizung_json_body[0]['fields']['Leistung'] = tasmota_values['Power_curr']

tasmota_heizung_json_body[0]['fields']['Import_kWh'] = tasmota_values['Total']

tasmota_heizung_json_body[0]['fields']['Export_kWh'] = tasmota_values['Total_out']

#print(tasmota_heizung_json_body)

except:

print("Fehler beim Lesen von Tasmota Haus")

# ------------------ Heizungsleistung berechnen ------------------

try:

heizung_json_body[0]['fields']['Leistung'] = tasmota_heizung_json_body[0]['fields']['Leistung']-tasmota_haus_json_body[0]['fields']['Leistung'] + heizung_json_body[0]['fields']['aktuelle_Gesamtwirkleistung']

if(tasmota_heizung_json_body[0]['fields']['Leistung']>=0 and tasmota_haus_json_body[0]['fields']['Leistung']>=0): # Voll Netzbetrieb

heizung_json_body[0]['fields']['Leistung_Netz'] = heizung_json_body[0]['fields']['Leistung']

heizung_json_body[0]['fields']['Leistung_PV'] = 0.0

elif(tasmota_heizung_json_body[0]['fields']['Leistung']<=0 and tasmota_haus_json_body[0]['fields']['Leistung']<=0): # PV Betrieb

heizung_json_body[0]['fields']['Leistung_Netz'] = 0.0

heizung_json_body[0]['fields']['Leistung_PV'] = heizung_json_body[0]['fields']['Leistung']

else: #Mischung

heizung_json_body[0]['fields']['Leistung_Netz'] = tasmota_heizung_json_body[0]['fields']['Leistung']

heizung_json_body[0]['fields']['Leistung_PV'] = tasmota_haus_json_body[0]['fields']['Leistung']*-1

# Modbus Leistung dazurechnen

heizung_json_body[0]['fields']['Leistung_Modbus'] = heizung_json_body[0]['fields']['aktuelle_Gesamtwirkleistung']

except:

print("Fehler beim Berechnen von Heizungsleistung")

# ------------------ Zählerstand Heizung berechnen ------------------

heizung_json_body[0]['fields']['Zaehlerstand_Einspeisung'] = tasmota_haus_json_body[0]['fields']['Export_kWh'] - tasmota_heizung_json_body[0]['fields']['Export_kWh']

heizung_json_body[0]['fields']['Zaehlerstand_Bezug'] = tasmota_heizung_json_body[0]['fields']['Import_kWh'] - tasmota_haus_json_body[0]['fields']['Import_kWh']

heizung_json_body[0]['fields']['Zaehlerstand_PV'] = heizung_json_body[0]["fields"]['Total_kwh']

print(heizung_json_body)

influxclient.write_points(heizung_json_body)

# except:

# print("Fehler beim Lesen von Modbuszähler Heizung")

time2 = time.perf_counter()

timedifference = time2-time1

if timedifference < 60:

time.sleep(60-timedifference)

except:

print("Fehler beim Auslesen vom Modbuszähler")

time.sleep(60)

Hinzu kommt hier die Verbindung zur Influx Datenbank (Z. 12) und das eigentliche Auslesen des Stromzählers ab Z. 57. Es werden auch noch andere Stromzähler, die über Tasmota angebunden sind, ausgelesen, um einige Werte zu berechnen. Wichtig hier ist auch die Variable relais_freigabe, die dafür sorgt, dass wenn gerade der Stromzähler ausgelesen wird, mit dem Setzen des Relais noch kurz gewartet wird, da dies nicht gleichzeitig passieren kann.

Bildquelle: waveshare.com, wikipedia.org

Putzfunktion für Raspberry Display

5. Februar 2023 / jjk1 / Keine Kommentare

Wenn mein Display (hier kannst du dir anschauen, wie ich es eingebaut habe) schmutzig ist, ist es ganz praktisch, wenn es eine „Putzfunktion“ gibt, die für eine kurze Zeit alle Eingaben deaktiviert, sodass beim Putzen nichts verstellt wird. Hier möchte ich dir zeigen, wie ich das umgesetzt habe.

Installation des Webservers

Für diese Funktion verwende ich einen Webserver, der ein Request entgegennimmt. Dieser führt dann ein Shell Skript aus, das die Eingaben vom Touchscreen abschaltet.

sudo apt install apache2 php

1	sudo apt install apache2 php

PHP Skript

Dann verwende ich ein einfaches PHP Skript, welches ein Shell-Skript als User „pi“ startet:

<?php
        exec('sudo su -c "/home/pi/cleanmode.sh" pi');

1 2	<?php exec('sudo su -c "/home/pi/cleanmode.sh" pi');

Dieses habe ich in /var/www/html/cleanmode.sh gespeichert.

Shell-Skript

Für das Shell-Skript muss man zuerst die ID des Touchscreens herausfinden. Mit folgendem Befehl lassen sich alle IDs anzeigen:

pi@raspberrypi:~ $ DISPLAY=:0 xinput list
⎡ Virtual core pointer                    	id=2	&#91;master pointer  (3)]
⎜   ↳ Virtual core XTEST pointer              	id=4	&#91;slave  pointer  (2)]
⎜   ↳ ILITEK ILITEK-TP Mouse                  	id=8	&#91;slave  pointer  (2)]
⎜   ↳ ILITEK ILITEK-TP                        	id=7	&#91;slave  pointer  (2)]
⎜   ↳ vc4                                     	id=6	&#91;slave  pointer  (2)]
⎣ Virtual core keyboard                   	id=3	&#91;master keyboard (2)]
    ↳ Virtual core XTEST keyboard             	id=5	&#91;slave  keyboard (3)]
    ↳ vc4                                     	id=9	&#91;slave  keyboard (3)]

pi@raspberrypi:~ $ DISPLAY=:0 xinput list

⎡ Virtual core pointer id=2 [master pointer (3)]

⎜ ↳ Virtual core XTEST pointer id=4 [slave pointer (2)]

⎜ ↳ ILITEK ILITEK-TP Mouse id=8 [slave pointer (2)]

⎜ ↳ ILITEK ILITEK-TP id=7 [slave pointer (2)]

⎜ ↳ vc4 id=6 [slave pointer (2)]

⎣ Virtual core keyboard id=3 [master keyboard (2)]

↳ Virtual core XTEST keyboard id=5 [slave keyboard (3)]

↳ vc4 id=9 [slave keyboard (3)]

Anschließend probiert man mit

DISPLAY=:0 xinput disable [ID]

1	DISPLAY=:0 xinput disable [ID]

alle IDs durch, bis der Touchscreen nicht mehr funktioniert. In meinem Fall war es die ID 7.

Folgendes Shell-Skript muss dann angepasst werden:

DISPLAY=:0 xinput disable 7
sleep 60
DISPLAY=:0 xinput enable 7

DISPLAY=:0 xinput disable 7

sleep 60

DISPLAY=:0 xinput enable 7

Die Zeit in Zeile 2 kann man ebenfalls nach Belieben anpassen. Mein Skript liegt in /home/pi/cleanmode.sh. Sollte das bei dir anders sein, musst du den Pfad im PHP Skript entsprechend ändern.

Den Benutzer www-data mit Root-Rechten ausstatten

Damit der User www-data (Dieser wird vom Webserver verwendet) das Shell-Skript als User pi ausführen kann, braucht er Root-Rechte.

ACHTUNG: Den Benutzer www-data mit Rootrechten auszustatten, ist ein großes Sicherheitsrisiko. Dies sollte man unter keinen Umständen auf einem vom Internet erreichbaren Webserver tun!

Wir öffnen dazu mit dem Befehl

sudo visudo

1	sudo visudo

Die Datei /etc/sudoers und tragen dort unter „User privilege specification“ folgende Zeile ein:

www-data ALL=NOPASSWD: ALL

1	www-data ALL=NOPASSWD: ALL

Nach dem Speichern mit Strg+O, dem Beenden mit Strg+X und einem Neustart hat der User www-data nun Root-Rechte. Öffnet man nun im Browser folgende URL:

http://[IP_DEINES_RPi]/cleanmode.sh

sollte sich der Touchscreen abschalten und nach 60 Sekunden wieder anschalten.

Putzfunktion in Homeassistant

Auf meinem Display läuft zur Zeit Homeassistant. Dort möchte ich die Putzfunktion gerne als Button haben. Außerdem möchte ich einen Timer, der mir anzeigt, wie viel Zeit ich noch habe, bis der Touchscreen wieder aktiviert wird.

In der config.yaml habe ich folgende Konfiguration hinterlegt:

rest_command:
  cleanmode:
    url: "http://[IP_MEINES_RPi]/cleanmode.php"

timer:
  putztimer:
    duration: "00:00:60"

rest_command:

cleanmode:

url: "http://[IP_MEINES_RPi]/cleanmode.php"

timer:

putztimer:

duration: "00:00:60"

Ersteres ist der Aufruf der URL, Zweiteres der Timer.

Anschließend habe ich im Homeassistant UI einen Button unter „Helfer“ erstellt.
Eine Automatisierung steuert dann das ganze, startet also den Timer und ruft dann die URL auf:

Homeassistant Automatisierung Putzfunktion

Und hier noch in Textform:

alias: Putzbutton
description: ""
trigger:
  - platform: state
    entity_id:
      - input_button.putzbutton
condition: []
action:
  - service: timer.start
    data:
      duration: "60"
    target:
      entity_id: timer.putztimer
  - service: rest_command.cleanmode
    data: {}
mode: single

alias: Putzbutton

description: ""

trigger:

- platform: state

entity_id:

- input_button.putzbutton

condition: []

action:

- service: timer.start

data:

duration: "60"

target:

entity_id: timer.putztimer

- service: rest_command.cleanmode

data: {}

mode: single

Solaranzeige Daten in Homeassistant

6. Januar 2023 / jjk1 / 2 Kommentare

Heute Morgen habe ich mich an ein Problem gesetzt, das ich schon länger habe: Wie bekomme ich die Daten meiner Solaranzeige in Homeassistant? Oder ist es vielleicht sinnvoller, die Homeassistant SolarEdge Modbus Integration zu verwenden und die Daten dann von Homeassistant in die InfluxDB zu schicken?
Ich habe mich für die erste Variante entschieden. Dabei ist ein kleines PHP Programm entstanden. Dort gibt man einen MQTT „Block“ ein und heraus kommt dabei eine fertige Homeassistant Konfiguration, die man nur noch kopieren muss. Eine ausführlichere Anleitung wie’s funktioniert ist auch dabei.

Link: https://jojokorpi.ddns.net/solaranzeigetohomeassistant
Quellcode: https://github.com/jjk4/solaranzeigetohomeassistant

Sprache wählen:

Neuste Beiträge

Neuste YouTube Videos

Über diese Website

Schlagwort: homeassistant

Ein Upgrade für den Homeserver Teil 11 – Homeassistant

Übersicht aller Artikel dieser Serie

Was ist Homeassistant?

Installationsmethoden von Homeassistant

Installation von Homeassistant

Einrichten von Homeassistant

Installation von HACS

Waveshare Modbus Relais in Homeassistant

Material

Aufbau

Mitgelieferte Software

Steuerung mit Minimalmodbus

Einbindung in Homeassistant

Gleichzeitig Modbus Relais und Stromzähler auslesen

Putzfunktion für Raspberry Display

Installation des Webservers

PHP Skript

Shell-Skript

Den Benutzer www-data mit Root-Rechten ausstatten

Putzfunktion in Homeassistant

Solaranzeige Daten in Homeassistant