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