diff --git a/examples/rtl_433_http_events.py b/examples/rtl_433_http_events.py
new file mode 100755
index 00000000..d509fda3
--- /dev/null
+++ b/examples/rtl_433_http_events.py
@@ -0,0 +1,95 @@
+#!/usr/bin/env python3
+
+"""Custom data handling example for rtl_433's HTTP (chunked) streaming API of JSON events."""
+
+# Start rtl_433 (`rtl_433 -F http`), then this script.
+# Needs the Requests package to be installed.
+
+import requests
+import json
+from time import sleep
+
+# You can run rtl_433 and this script on different machines,
+# start rtl_433 with `-F http:0.0.0.0`, and change
+# to e.g. `HTTP_HOST = "192.168.1.100"` (use your server ip) below.
+HTTP_HOST = "127.0.0.1"
+HTTP_PORT = 8433
+
+
+def stream_events():
+ url = f'http://{HTTP_HOST}:{HTTP_PORT}/events'
+ headers = {'Accept': 'application/json'}
+
+ # You will receive JSON events, one per line terminated with CRLF.
+ # On Events and Stream endpoints a keep-alive of CRLF will be send every 60 seconds.
+ response = requests.get(url, headers=headers, timeout=70, stream=True)
+ print(f'Connected to {url}')
+
+ for chunk in response.iter_content(chunk_size=None):
+ yield chunk
+
+
+def handle_event(line):
+ try:
+ # Decode the message as JSON
+ data = json.loads(line)
+
+ #
+ # Change for your custom handling below, this is a simple example
+ #
+ label = data["model"]
+ if "channel" in data:
+ label += ".CH" + str(data["channel"])
+ elif "id" in data:
+ label += ".ID" + str(data["id"])
+
+ # E.g. match `model` and `id` to a descriptive name.
+ if data["model"] == "LaCrosse-TX" and data["id"] == 123:
+ label = "Living Room"
+
+ if "battery_ok" in data:
+ if data["battery_ok"] == 0:
+ print(label + ' Battery empty!')
+
+ if "temperature_C" in data:
+ print(label + ' Temperature ', data["temperature_C"])
+
+ if "humidity" in data:
+ print(label + ' Humidity ', data["humidity"])
+
+ except KeyError:
+ # Ignore unknown message data and continue
+ pass
+
+ except ValueError as e:
+ # Warn on decoding errors
+ print(f'Event format not recognized: {e}')
+
+
+def rtl_433_listen():
+ """Listen to all messages in a loop forever."""
+
+ # Loop forever
+ while True:
+ try:
+ # Open the HTTP (chunked) streaming API of JSON events
+ for chunk in stream_events():
+ # print(chunk)
+ chunk = chunk.rstrip()
+ if not chunk:
+ # filter out keep-alive empty lines
+ continue
+ # Decode the JSON message
+ handle_event(chunk)
+
+ except requests.ConnectionError:
+ print('Connection failed, retrying...')
+ sleep(5)
+
+
+if __name__ == "__main__":
+ try:
+ rtl_433_listen()
+ except KeyboardInterrupt:
+ print('\nExiting.')
+ pass
diff --git a/examples/rtl_433_http_stream.py b/examples/rtl_433_http_stream.py
new file mode 100755
index 00000000..e7c1e21a
--- /dev/null
+++ b/examples/rtl_433_http_stream.py
@@ -0,0 +1,95 @@
+#!/usr/bin/env python3
+
+"""Custom data handling example for rtl_433's HTTP (line) streaming API of JSON events."""
+
+# Start rtl_433 (`rtl_433 -F http`), then this script.
+# Needs the Requests package to be installed.
+
+import requests
+import json
+from time import sleep
+
+# You can run rtl_433 and this script on different machines,
+# start rtl_433 with `-F http:0.0.0.0`, and change
+# to e.g. `HTTP_HOST = "192.168.1.100"` (use your server ip) below.
+HTTP_HOST = "127.0.0.1"
+HTTP_PORT = 8433
+
+
+def stream_lines():
+ url = f'http://{HTTP_HOST}:{HTTP_PORT}/stream'
+ headers = {'Accept': 'application/json'}
+
+ # You will receive JSON events, one per line terminated with CRLF.
+ # On Events and Stream endpoints a keep-alive of CRLF will be send every 60 seconds.
+ response = requests.get(url, headers=headers, timeout=70, stream=True)
+ print(f'Connected to {url}')
+
+ for chunk in response.iter_lines():
+ yield chunk
+
+
+def handle_event(line):
+ try:
+ # Decode the message as JSON
+ data = json.loads(line)
+
+ #
+ # Change for your custom handling below, this is a simple example
+ #
+ label = data["model"]
+ if "channel" in data:
+ label += ".CH" + str(data["channel"])
+ elif "id" in data:
+ label += ".ID" + str(data["id"])
+
+ # E.g. match `model` and `id` to a descriptive name.
+ if data["model"] == "LaCrosse-TX" and data["id"] == 123:
+ label = "Living Room"
+
+ if "battery_ok" in data:
+ if data["battery_ok"] == 0:
+ print(label + ' Battery empty!')
+
+ if "temperature_C" in data:
+ print(label + ' Temperature ', data["temperature_C"])
+
+ if "humidity" in data:
+ print(label + ' Humidity ', data["humidity"])
+
+ except KeyError:
+ # Ignore unknown message data and continue
+ pass
+
+ except ValueError as e:
+ # Warn on decoding errors
+ print(f'Event format not recognized: {e}')
+
+
+def rtl_433_listen():
+ """Listen to all messages in a loop forever."""
+
+ # Loop forever
+ while True:
+ try:
+ # Open the HTTP (line) streaming API of JSON events
+ for chunk in stream_lines():
+ # print(chunk)
+ chunk = chunk.rstrip()
+ if not chunk:
+ # filter out keep-alive empty lines
+ continue
+ # Decode the JSON message
+ handle_event(chunk)
+
+ except requests.ConnectionError:
+ print('Connection failed, retrying...')
+ sleep(5)
+
+
+if __name__ == "__main__":
+ try:
+ rtl_433_listen()
+ except KeyboardInterrupt:
+ print('\nExiting.')
+ pass
diff --git a/examples/rtl_433_http_ws.py b/examples/rtl_433_http_ws.py
new file mode 100755
index 00000000..621fc490
--- /dev/null
+++ b/examples/rtl_433_http_ws.py
@@ -0,0 +1,99 @@
+#!/usr/bin/env python3
+
+"""Custom data handling example for rtl_433's HTTP WebSocket API of JSON events."""
+
+# Start rtl_433 (`rtl_433 -F http`), then this script.
+# Needs the websocket-client package to be installed.
+
+import websocket
+import json
+from time import sleep
+
+# You can run rtl_433 and this script on different machines,
+# start rtl_433 with `-F http:0.0.0.0`, and change
+# to e.g. `HTTP_HOST = "192.168.1.100"` (use your server ip) below.
+HTTP_HOST = "127.0.0.1"
+HTTP_PORT = 8433
+
+
+def ws_events():
+ url = f'ws://{HTTP_HOST}:{HTTP_PORT}/ws'
+ ws = websocket.WebSocket()
+ ws.connect(url)
+
+ # You will receive JSON events, one per message.
+ print(f'Connected to {url}')
+
+ while True:
+ yield ws.recv()
+
+
+def handle_event(line):
+ try:
+ # Decode the message as JSON
+ data = json.loads(line)
+
+ #
+ # Change for your custom handling below, this is a simple example
+ #
+ label = data["model"]
+ if "channel" in data:
+ label += ".CH" + str(data["channel"])
+ elif "id" in data:
+ label += ".ID" + str(data["id"])
+
+ # E.g. match `model` and `id` to a descriptive name.
+ if data["model"] == "LaCrosse-TX" and data["id"] == 123:
+ label = "Living Room"
+
+ if "battery_ok" in data:
+ if data["battery_ok"] == 0:
+ print(label + ' Battery empty!')
+
+ if "temperature_C" in data:
+ print(label + ' Temperature ', data["temperature_C"])
+
+ if "humidity" in data:
+ print(label + ' Humidity ', data["humidity"])
+
+ except KeyError:
+ # Ignore unknown message data and continue
+ pass
+
+ except ValueError as e:
+ # Warn on decoding errors
+ print(f'Event format not recognized: {e}')
+
+
+def rtl_433_listen():
+ """Listen to all messages in a loop forever."""
+
+ # Loop forever
+ while True:
+ try:
+ # Open the HTTP WebSocket API of JSON events
+ for chunk in ws_events():
+ # print(chunk)
+ chunk = chunk.rstrip()
+ if not chunk:
+ # filter out keep-alive empty lines
+ continue
+ # Decode the JSON message
+ handle_event(chunk)
+
+ except ConnectionRefusedError:
+ print('Connection refused, retrying...')
+ sleep(5)
+ pass
+
+ except websocket._exceptions.WebSocketConnectionClosedException:
+ print('Connection failed, retrying...')
+ sleep(5)
+
+
+if __name__ == "__main__":
+ try:
+ rtl_433_listen()
+ except KeyboardInterrupt:
+ print('\nExiting.')
+ pass