Commit 0a062438 authored by Olivier Kaufmann's avatar Olivier Kaufmann
Browse files

Updates scripts and notebooks; fixes missing mqtt_setup.py

Showing with 18 additions and 0 deletions
+18 -0
mqtt_setup.py 0 → 100644
from settings import MQTT_CONFIG
import paho.mqtt.client as mqtt
def on_message(client, userdata, message):
m = str(message.payload.decode("utf-8"))
print(f'message received {m}')
print(f'topic: {message.topic}')
print(f'qos: {message.qos}')
print(f'retain flag: {message.retain}')
client.publish(MQTT_CONFIG['measurements_topic'], f'{m} 45 ohm.m')
def mqtt_client_setup():
client = mqtt.Client(MQTT_CONFIG['client_id'], protocol=4) # create new client instance
client.connect(MQTT_CONFIG['mqtt_broker'])
client.on_message = on_message
return client, MQTT_CONFIG['measurements_topic']
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment