Skip to content

Commit f0c5f46

Browse files
committed
fix(data_frame): parsing empty value as numpy.NaN
1 parent 50a47f0 commit f0c5f46

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

influxdb_client/client/flux_csv_parser.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -268,6 +268,7 @@ def parse_record(self, table_index, table, csv):
268268
return record
269269

270270
def _to_value(self, str_val, column):
271+
271272
if str_val == '' or str_val is None:
272273
default_value = column.default_value
273274
if default_value == '' or default_value is None:

tests/test_FluxCSVParser.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -267,15 +267,14 @@ def test_pandas_null_bool_types(self):
267267
data = "#datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string,string,string,string,boolean\n" \
268268
"#group,false,false,true,true,true,true,true,true,false\n" \
269269
"#default,_result,,,,,,,,\n" \
270-
",result,table,_start,_stop,_field,_measurement,host,region,value4\n" \
270+
",result,table,_start,_stop,_field,_measurement,host,region,value\n" \
271271
",,0,1977-09-21T00:12:43.145224192Z,2018-07-16T11:21:02.547596934Z,free,mem,A,west,true\n" \
272272
",,0,1977-09-21T00:12:43.145224192Z,2018-07-16T11:21:02.547596934Z,free,mem,A,west,\n"
273273

274274
parser = self._parse(data=data, serialization_mode=FluxSerializationMode.dataFrame,
275275
response_metadata_mode=FluxResponseMetadataMode.full)
276276
df = list(parser.generator())[0]
277-
print(df.to_string())
278-
self.assertEqual('bool', df.dtypes['value4'].name)
277+
self.assertEqual('bool', df.dtypes['value'].name)
279278

280279
def test_parse_without_datatype(self):
281280
data = ",result,table,_start,_stop,_field,_measurement,host,region,_value2,value1,value_str\n" \

0 commit comments

Comments
 (0)