diff --git a/mqtt2console.py b/mqtt2console.py new file mode 100644 index 0000000..458009a --- /dev/null +++ b/mqtt2console.py @@ -0,0 +1,28 @@ +''' +Created on 20.05.2015 + +@author: wn +''' + +import paho.mqtt.client as mqtt +import json + + +def on_message(client, userdata, msg): +# print(msg.topic+" "+str(msg.payload)) + j = json.loads(msg.payload) + print(json.dumps(j,indent=4, separators=(',', ': '))) + print + print + + +if __name__ == '__main__': + print("Starting client ...") + + client = mqtt.Client() + client.on_message = on_message + client.connect("172.16.2.15", 1883, 60) + client.subscribe("IoT/Measurement/MeterbusHub") + + client.loop_forever() +