Diff: client.py

Revision:

5:447d7ad9810c

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/client.py	Wed Apr 11 20:16:27 2018 +0000
@@ -0,0 +1,47 @@
+#!/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()
\ No newline at end of file