Skip to content
This repository was archived by the owner on Oct 29, 2024. It is now read-only.

Fixed/Implemented Chunked Read. #585

Closed
wants to merge 2 commits into from
Closed

Fixed/Implemented Chunked Read. #585

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3189185
Fixed/Implemented Chunked Read.
gopalkcfx May 4, 2018
0f8d5ff
Merge branch 'master' into master
gopalkpd May 4, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 5 additions & 3 deletions influxdb/client.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ def switch_user(self, username, password):
self._username = username
self._password = password

def request(self, url, method='GET', params=None, data=None,
def request(self, url, method='GET', params=None, data=None, stream=False,
expected_response_code=200, headers=None):
"""Make a HTTP request to the InfluxDB API.

Expand Down Expand Up @@ -246,6 +246,7 @@ def request(self, url, method='GET', params=None, data=None,
auth=(self._username, self._password),
params=params,
data=data,
stream=stream,
headers=headers,
proxies=self._proxies,
verify=self._verify_ssl,
Expand Down Expand Up @@ -315,8 +316,8 @@ def write(self, data, params=None, expected_response_code=204,

@staticmethod
def _read_chunked_response(response, raise_errors=True):
result_set = {}
for line in response.iter_lines():
result_set = {}
if isinstance(line, bytes):
line = line.decode('utf-8')
data = json.loads(line)
Expand All @@ -325,7 +326,7 @@ def _read_chunked_response(response, raise_errors=True):
if isinstance(result[_key], list):
result_set.setdefault(
_key, []).extend(result[_key])
return ResultSet(result_set, raise_errors=raise_errors)
yield ResultSet(result_set, raise_errors=raise_errors)

def query(self,
query,
Expand Down Expand Up @@ -391,6 +392,7 @@ def query(self,
method='GET',
params=params,
data=None,
stream=True if chunked else False,
expected_response_code=expected_response_code
)

Expand Down