From 211271f3e56da65cea6147e879f39ce6d32f3d3f Mon Sep 17 00:00:00 2001 From: tilman Date: Wed, 24 Aug 2022 14:33:07 +0000 Subject: [PATCH] doorbell.py - send MQTT --- doorbell/klingel_sender_nano_serial/doorbell.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/doorbell/klingel_sender_nano_serial/doorbell.py b/doorbell/klingel_sender_nano_serial/doorbell.py index c30634d..a1711f7 100644 --- a/doorbell/klingel_sender_nano_serial/doorbell.py +++ b/doorbell/klingel_sender_nano_serial/doorbell.py @@ -7,6 +7,7 @@ import urllib.request import logging import logging.handlers as handlers import time +import json logger = logging.getLogger('Rotating Log') logger.setLevel(logging.INFO) @@ -30,6 +31,12 @@ while True: if (data == 'RING'): try: response = urllib.request.urlopen('http://192.168.178.60/bell/on', timeout=5).read().decode('utf-8') + + # send MQTT + headers = {"Content-Type": "application/json","Authorization": "Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJjYjY5NjA5NmY0N2E0NmZlOGEzYjczOGYzYmUzOTk5ZSIsImlhdCI6MTY2MTM0NDgxOSwiZXhwIjoxOTc2NzA0ODE5fQ.z9fzbVOA1Pbur3Zb07481n-SoYesj8cetw-CX6WPmTs"} + data = json.dumps({'payload': 'RING', 'topic': 'lewe/doorbell', 'retain': 'False'}).encode('utf8') + reqest = urllib.request.Request("https://www.nodebucket.de:8123/api/services/mqtt/publish", data, headers) + response = urllib.request.urlopen(reqest) except Exception: logger.error("Could not ring doorbell") # logger.exception("Could not ring doorbell")