lab9
Dependencies: ATParser MPL3115A2 TSL2561 mbed
client.py@10:ce4aadfeeb7d, 2018-04-28 (annotated)
- Committer:
- kmhatre
- Date:
- Sat Apr 28 00:56:22 2018 +0000
- Revision:
- 10:ce4aadfeeb7d
- Parent:
- 5:447d7ad9810c
lab9
Who changed what in which revision?
User | Revision | Line number | New 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() |