We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent afcfd25 commit b4ceab9Copy full SHA for b4ceab9
influxdb/_dataframe_client.py
@@ -363,7 +363,7 @@ def _convert_dataframe_to_lines(self,
363
tag_df = self._stringify_dataframe(
364
tag_df, numeric_precision, datatype='tag')
365
366
- # join preprendded tags, leaving None values out
+ # join prepended tags, leaving None values out
367
tags = tag_df.apply(
368
lambda s: [',' + s.name + '=' + v if v else '' for v in s])
369
tags = tags.sum(axis=1)
@@ -392,6 +392,8 @@ def _convert_dataframe_to_lines(self,
392
field_df.columns[1:]]
393
field_df = field_df.where(~mask_null, '') # drop Null entries
394
fields = field_df.sum(axis=1)
395
+ # take out leading , where first column has a Null value
396
+ fields = fields.str.lstrip(",")
397
del field_df
398
399
# Generate line protocol string
0 commit comments