krishnazure
diff --git a/‎influxdb/influxdb08/client.py
Lines changed: 7 additions & 1 deletion b/‎influxdb/influxdb08/client.py
Lines changed: 7 additions & 1 deletion
diff --git a/‎tests/influxdb/influxdb08/client_test.py
Lines changed: 39 additions & 0 deletions b/‎tests/influxdb/influxdb08/client_test.py
Lines changed: 39 additions & 0 deletions
@@ -448,7 +448,13 @@ def _query(self, query, time_precision='s', chunked=False):
         )
 
         if chunked:
-            return list(chunked_json.loads(response.content.decode()))
+            decoded = {}
+            try:
+                decoded = chunked_json.loads(response.content.decode())
+            except UnicodeDecodeError:
+                decoded = chunked_json.loads(response.content.decode('utf-8'))
+            finally:
+                return list(decoded)
         else:
             return response.json()
 
 
@@ -17,6 +17,16 @@
 from influxdb.influxdb08 import InfluxDBClient
 from influxdb.influxdb08.client import session
 
+import sys
+if sys.version < '3':
+    import codecs
+
+    def u(x):
+        return codecs.unicode_escape_decode(x)[0]
+else:
+    def u(x):
+        return x
+
 
 def _build_response_object(status_code=200, content=""):
     resp = requests.Response()
@@ -366,6 +376,35 @@ def test_query_chunked(self):
                 [example_object, example_object]
             )
 
+    def test_query_chunked_unicode(self):
+        cli = InfluxDBClient(database='db')
+        example_object = {
+            'points': [
+                [1415206212980, 10001, u('unicode-\xcf\x89')],
+                [1415197271586, 10001, u('more-unicode-\xcf\x90')]
+            ],
+            'name': 'foo',
+            'columns': [
+                'time',
+                'sequence_number',
+                'val'
+            ]
+        }
+        example_response = \
+            json.dumps(example_object) + json.dumps(example_object)
+
+        with requests_mock.Mocker() as m:
+            m.register_uri(
+                requests_mock.GET,
+                "http://localhost:8086/db/db/series",
+                text=example_response
+            )
+
+            self.assertListEqual(
+                cli.query('select * from foo', chunked=True),
+                [example_object, example_object]
+            )
+
     @raises(Exception)
     def test_query_fail(self):
         with _mocked_session('get', 401):