berferd hat geschrieben: ↑Mo 7. Sep 2020, 17:08
Danke!
Was mir konkret z.B. noch nicht klar ist
Der rtl_433 "Treiber" kümmert sich um den DVB-T Stick und stellt decodierte 433Mhz Daten von den Geräten, die er kennt, zur Verfügung:
Code: Alles auswählen
pi@raspi200:~/systemdienste $ rtl_433
rtl_433 version 20.02-137-g1c0ac48 branch master at 202008302143 inputs file rtl_tcp RTL-SDR
Use -h for usage help and see https://triq.org/ for documentation.
Trying conf file at "rtl_433.conf"...
Trying conf file at "/home/pi/.config/rtl_433/rtl_433.conf"...
Trying conf file at "/usr/local/etc/rtl_433/rtl_433.conf"...
Trying conf file at "/etc/rtl_433/rtl_433.conf"...
Registered 135 out of 164 device decoding protocols [ 1-4 8 11-12 15-17 19-21 23 25-26 29-36 38-60 63 67-71 73-100 102-105 108-116 119 121 124-128 130-149 151-161 163-164 ]
Detached kernel driver
Found Rafael Micro R820T tuner
Exact sample rate is: 250000.000414 Hz
[R82XX] PLL not locked!
Sample rate set to 250000 S/s.
Tuner gain set to Auto.
Tuned to 433.920MHz.
Allocating 15 zero-copy buffers
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
time : 2020-09-07 17:31:15
model : GT-WT02 ID Code : 20
Channel : 2 Battery : 1 Temperature: 21.7 C Humidity : 42 % Button : 0 Integrity : CHECKSUM
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
time : 2020-09-07 17:31:15
model : Springfield-Soil SID : 20
Channel : 2 Battery : 1 Transmit : AUTO Temperature: 21.7 C Moisture : 5 Button : 0 Integrity : CHECKSUM
Der Befehl
rtl_433 -F json
bringt den Treiber dazu, json Objekte auszuwerfen
Code: Alles auswählen
{"time" : "2020-09-07 17:34:15", "model" : "Prologue-TH", "subtype" : 5, "id" : 187, "channel" : 1, "battery_ok" : 1, "temperature_C" : 19.600, "humidity" : 26, "button" : 0}
{"time" : "2020-09-07 17:34:17", "model" : "Hideki-TS04", "id" : 4, "channel" : 1, "battery_ok" : 1, "temperature_C" : 21.100, "humidity" : 54, "mic" : "CRC"}
{"time" : "2020-09-07 17:34:17", "model" : "Hideki-TS04", "id" : 4, "channel" : 1, "battery_ok" : 1, "temperature_C" : 21.100, "humidity" : 54, "mic" : "CRC"}
Dann gibt es eine Software, die die JSON -Objekte per MQTT an den MQTT-Broker schickt,
das ist das rtl2mqtt.py script.
Das wird in der config.py angepasst, das es den MQTT-Boker kennt, entweder den localhost oder hat der Raspi an dem der DVB-T Stick hängt.
config.py
Code: Alles auswählen
# Config section
# Uncomment these lines if your MQTT server requires authentication
#MQTT_USER="mqtt-user"
#MQTT_PASS="mqtt-password"
MQTT_HOST="192.168.1.200"
MQTT_PORT=1883
MQTT_TOPIC="sensors/rtl_433"
MQTT_QOS=0
# End config section
In der rtl2mqtt.py wird beim erkennen des Stings time dann das JSON-Objekt welches time enthält an den MQTT-Brocker gesendet.
Von dem MQTT-Broker holt sich dann Nodered alles was das topic sensors/rtl-433/ hat, das Topic gibt man in der config.py an.
Warum der Aufwand mit dem MQTT-Broker?
Das ist hilfreich wenn der Raspi mit dem DVB-T Stick unter dem Dach hängt und der Server mit der Datenbank im Keller oder im Internet steht.
Dann sendet der Raspi mittels MQTT die Daten an den MQTT Broker irgenwo und kann dann von überall und von jedem Ort gelesen werden.
Also es kann also so sein, das der Raspi mit dem Stick auf dem Dachboden steht und die Daten an den Broker im Internet sendet, weil man da einen Server1 hat. Dann kann man mit Nodered auf dem Server2 die Daten von Server1 "abonieren" und in die Datenbank auf dem ServerKeller speichern. Die Darstellung der Daten kann dann auch wieder der Server1 im Internet manchen.
Diese verknotung macht man dann mit Nodered. Der Server auf welchem Nodered läuft hat aber nicht unbedingt was mit dem ServerKeller zu tun auf dem die Datenbank läuft.
In meinem Beispiel läuft alles auf dem Raspi.
rtl2mqtt.py
Code: Alles auswählen
#!/usr/bin/env python3
# -*- coding: UTF-8 -*-
import subprocess
import sys
import time
import paho.mqtt.client as mqtt
import os
import json
from config import *
subtopic=" "
rtl_433_cmd = "/usr/local/bin/rtl_433 -F json" # linux
# Define MQTT event callbacks
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
def on_disconnect(client, userdata, rc):
if rc != 0:
print("Unexpected disconnection.")
def on_message(client, obj, msg):
print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
def on_publish(client, obj, mid):
print("mid: " + str(mid))
def on_subscribe(client, obj, mid, granted_qos):
print("Subscribed: " + str(mid) + " " + str(granted_qos))
def on_log(client, obj, level, string):
print(string)
# Setup MQTT connection
mqttc = mqtt.Client()
# Assign event callbacks
#mqttc.on_message = on_message
mqttc.on_connect = on_connect
#mqttc.on_publish = on_publish
#mqttc.on_subscribe = on_subscribe
mqttc.on_disconnect = on_disconnect
# Uncomment to enable debug messages
#mqttc.on_log = on_log
# Uncomment the next line if your MQTT server requires authentication
#mqttc.username_pw_set(MQTT_USER, password=MQTT_PASS)
mqttc.connect(MQTT_HOST, MQTT_PORT, 60)
mqttc.loop_start()
# Start RTL433 listener
rtl433_proc = subprocess.Popen(rtl_433_cmd.split(),stdout=subprocess.PIPE,stderr=subprocess.STDOUT,universal_newlines=True)
while True:
try:
for line in iter(rtl433_proc.stdout.readline, '\n'):
if "time" in line:
mqttc.publish(MQTT_TOPIC, payload=line,qos=MQTT_QOS)
except KeyboardInterrupt:
raise
except:
print ("Fehler") # report error and proceed
.
. @Axel, hast du den ggf. noch? 
