|
@@ -152,7 +152,7 @@ class InfluxdbHandler:
|
|
|
for column in measurement_columns:
|
|
|
try:
|
|
|
self.client.write_points(
|
|
|
- dataframe=dataframe[column].to_frame(),
|
|
|
+ dataframe=dataframe[[column] + tag_columns],
|
|
|
measurement=column,
|
|
|
tag_columns=tag_columns,
|
|
|
protocol='line',
|