drpuur
/
mqtt2log
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

use new API Version, update python version

This commit is contained in:
Joerg Lehmann 2024-10-19 11:38:54 +02:00
parent 2366aa7214
commit 6a176dae0c
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Dockerfile
View File

@ -1,4 +1,4 @@
FROM python:3.10-slim FROM python:3.12-slim
ADD . /code ADD . /code
WORKDIR /code WORKDIR /code
RUN pip install --root-user-action ignore -r requirements.txt RUN pip install --root-user-action ignore -r requirements.txt

6
mqtt2log.py
View File

@ -11,9 +11,9 @@ MQTT_PASSWORD = 'mqtt7355@'
MQTT_TOPIC = 'shellies/events/rpc' MQTT_TOPIC = 'shellies/events/rpc'
MQTT_CLIENT_ID = 'MQTT_Logfile_Bridge' MQTT_CLIENT_ID = 'MQTT_Logfile_Bridge'
def on_connect(client, userdata, flags, rc): def on_connect(client, userdata, flags, reason_code, properties):
""" The callback for when the client receives a CONNACK response from the server.""" """ The callback for when the client receives a CONNACK response from the server."""
print('Connected with result code ' + str(rc)) print('Connected with result code ' + reason_code)
client.subscribe(MQTT_TOPIC) client.subscribe(MQTT_TOPIC)
def _parse_mqtt_message(topic, payload): def _parse_mqtt_message(topic, payload):
@ -51,7 +51,7 @@ def on_message(client, userdata, msg):
return return
def main(): def main():
mqtt_client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION1,MQTT_CLIENT_ID) mqtt_client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2,MQTT_CLIENT_ID)
mqtt_client.username_pw_set(MQTT_USER, MQTT_PASSWORD) mqtt_client.username_pw_set(MQTT_USER, MQTT_PASSWORD)
mqtt_client.on_connect = on_connect mqtt_client.on_connect = on_connect
mqtt_client.on_message = on_message mqtt_client.on_message = on_message