CPS-Lab / Mbed 2 deprecated Lab9

rgjefklgf

Dependencies:   mbed ATParser MPL3115A2 TSL2561

client.py@6:e7d266de146a, 2018-04-20 (annotated)

Committer:
dgutsch
Date:
Fri Apr 20 21:47:49 2018 +0000
Revision:
6:e7d266de146a
Parent:
5:447d7ad9810c 
she works

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dgutsch 5:447d7ad9810c 1 #!/usr/bin/env python
dgutsch 5:447d7ad9810c 2
dgutsch 5:447d7ad9810c 3 import paho.mqtt.client as mqtt
dgutsch 5:447d7ad9810c 4 import time
dgutsch 5:447d7ad9810c 5 import json
dgutsch 5:447d7ad9810c 6 import binascii, base64
dgutsch 5:447d7ad9810c 7
dgutsch 5:447d7ad9810c 8
dgutsch 5:447d7ad9810c 9 def unpackage_json(s):
dgutsch 5:447d7ad9810c 10 #print s
dgutsch 5:447d7ad9810c 11 attribs = s.split(",")
dgutsch 5:447d7ad9810c 12 encodedMess = ''
dgutsch 5:447d7ad9810c 13 for item in attribs:
dgutsch 5:447d7ad9810c 14 if item[:6] == '\"data\"':
dgutsch 5:447d7ad9810c 15 encodedMess = item[8:-1]
dgutsch 5:447d7ad9810c 16 #print encodedMess
dgutsch 5:447d7ad9810c 17
dgutsch 5:447d7ad9810c 18 #return bytearray.fromhex(encodedMess)
dgutsch 5:447d7ad9810c 19 return base64.standard_b64decode(encodedMess)
dgutsch 5:447d7ad9810c 20
dgutsch 5:447d7ad9810c 21
dgutsch 5:447d7ad9810c 22 def on_message(client, userdata, message):
dgutsch 5:447d7ad9810c 23 #print message.timestamp
dgutsch 5:447d7ad9810c 24 #print message.topic
dgutsch 5:447d7ad9810c 25 # unpackage and increment data
dgutsch 5:447d7ad9810c 26 #print message.payload
dgutsch 5:447d7ad9810c 27 print "light reading:\t" + unpackage_json(message.payload)
dgutsch 5:447d7ad9810c 28 # print "received a message"
dgutsch 5:447d7ad9810c 29 # print data.length()
dgutsch 5:447d7ad9810c 30 # print("Message Received", message.payload)
dgutsch 5:447d7ad9810c 31 # print("message topic =",message.topic)
dgutsch 5:447d7ad9810c 32 # print("message qos=",message.qos)
dgutsch 5:447d7ad9810c 33 #print("message retain flag=",message.retain)
dgutsch 5:447d7ad9810c 34
dgutsch 5:447d7ad9810c 35
dgutsch 5:447d7ad9810c 36 # broker_address = "test.mosquitto.org"
dgutsch 5:447d7ad9810c 37 # broker_address = "18.221.88.223"
dgutsch 5:447d7ad9810c 38 broker_address = "pivot.iuiot.org"
dgutsch 5:447d7ad9810c 39 client = mqtt.Client()
dgutsch 5:447d7ad9810c 40 client.on_message=on_message
dgutsch 5:447d7ad9810c 41 client.connect(broker_address)
dgutsch 5:447d7ad9810c 42 client.loop_start()
dgutsch 5:447d7ad9810c 43 client.subscribe("lora/00-80-00-00-04-00-59-02/up")
dgutsch 5:447d7ad9810c 44 while True:
dgutsch 5:447d7ad9810c 45 pass
dgutsch 5:447d7ad9810c 46 #time.sleep(30)
dgutsch 5:447d7ad9810c 47 client.loop_stop()