|
|
@@ -129,6 +129,19 @@ def on_message(mosq, userdata, msg):
|
|
|
logging.info("Topic %s contains non-JSON payload [%s]" %
|
|
|
(msg.topic, msg.payload))
|
|
|
return
|
|
|
+ elif type == 'u':
|
|
|
+ '''JSON: try and load the JSON string from payload and use
|
|
|
+ subkeys to pass to Carbon'''
|
|
|
+ try:
|
|
|
+ st = json.loads(msg.payload)
|
|
|
+ print st['SHT3X-0x45']
|
|
|
+ for k in st['SHT3X-0x45']:
|
|
|
+ if is_number(st['SHT3X-0x45'][k]):
|
|
|
+ lines.append("%s.%s %f %d" % (carbonkey, k, float(st['SHT3X-0x45'][k]), now))
|
|
|
+ except:
|
|
|
+ logging.info("Topic %s contains non-JSON payload [%s]" %
|
|
|
+ (msg.topic, msg.payload))
|
|
|
+ return
|
|
|
|
|
|
|
|
|
|
