From 0267584aad7b5eb55284c4ecbf8a6baa1ab6bc4c Mon Sep 17 00:00:00 2001 From: Joshua Gourneau Date: Tue, 19 Aug 2014 15:32:15 -0700 Subject: [PATCH] query works with chucks now. --- influxdb/client.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/influxdb/client.py b/influxdb/client.py index 41908e82..ef03b012 100644 --- a/influxdb/client.py +++ b/influxdb/client.py @@ -282,11 +282,14 @@ def query(self, query, time_precision='s', chunked=False): status_code=200 ) - try: - res = json.loads(response.content) - except TypeError: - # must decode in python 3 - res = json.loads(response.content.decode('utf8')) + if chunked: + res = json.loads("[" + response.content.decode('utf8').replace("}{", "},\n{") + "]") + else: + try: + res = json.loads(response.content) + except TypeError: + # must decode in python 3 + res = json.loads(response.content.decode('utf8')) return res