File content as of revision 6:e7d266de146a:

#!/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()