lab9
Dependencies: ATParser MPL3115A2 TSL2561 mbed
client.py
- Committer:
- dgutsch
- Date:
- 2018-04-11
- Revision:
- 5:447d7ad9810c
File content as of revision 5:447d7ad9810c:
#!/usr/bin/env python import paho.mqtt.client as mqtt import time import json import binascii, base64 def unpackage_json(s): #print s attribs = s.split(",") encodedMess = '' for item in attribs: if item[:6] == '\"data\"': encodedMess = item[8:-1] #print encodedMess #return bytearray.fromhex(encodedMess) return base64.standard_b64decode(encodedMess) def on_message(client, userdata, message): #print message.timestamp #print message.topic # unpackage and increment data #print message.payload print "light reading:\t" + unpackage_json(message.payload) # print "received a message" # print data.length() # print("Message Received", message.payload) # print("message topic =",message.topic) # print("message qos=",message.qos) #print("message retain flag=",message.retain) # broker_address = "test.mosquitto.org" # broker_address = "18.221.88.223" broker_address = "pivot.iuiot.org" client = mqtt.Client() client.on_message=on_message client.connect(broker_address) client.loop_start() client.subscribe("lora/00-80-00-00-04-00-59-02/up") while True: pass #time.sleep(30) client.loop_stop()