Authored by wuxiao

解析json

... ... @@ -43,6 +43,7 @@ while True:
db = 'error'
measurement = Config.debug_channel+time.strftime('_%Y%m%d')
data['data'] = json.loads(data['data'])
json_body = dict(data['data'],**data['tags'])
mongodb_insert(db,measurement,json_body)
... ... @@ -50,6 +51,7 @@ while True:
db = 'error'
measurement = Config.shutdown_channel+time.strftime('_%Y%m%d')
data['data'] = json.loads(data['data'])
json_body = dict(data['data'],**data['tags'])
mongodb_insert(db,measurement,json_body)
... ...