diff --git a/src/JiShe.CollectBus.IoTDBProvider/Provider/DeviceMetadata.cs b/src/JiShe.CollectBus.IoTDBProvider/Provider/DeviceMetadata.cs
index 50aa8f7..6bdbd56 100644
--- a/src/JiShe.CollectBus.IoTDBProvider/Provider/DeviceMetadata.cs
+++ b/src/JiShe.CollectBus.IoTDBProvider/Provider/DeviceMetadata.cs
@@ -20,7 +20,7 @@ namespace JiShe.CollectBus.IoTDBProvider
///
/// 测量值集合,用于构建Table的测量值,也就是columnNames参数
///
- public List ColumnNames { get; } = new();
+ public List ColumnNames { get; set; } = new();
///
/// 列类型集合,用于构建Table的列类型,也就是columnCategories参数
@@ -30,6 +30,6 @@ namespace JiShe.CollectBus.IoTDBProvider
///
/// 值类型集合,用于构建Table的值类型,也就是dataTypes参数
///
- public ListDataTypes { get; } = new();
+ public List DataTypes { get; } = new();
}
}
diff --git a/src/JiShe.CollectBus.IoTDBProvider/Provider/IoTDBProvider.cs b/src/JiShe.CollectBus.IoTDBProvider/Provider/IoTDBProvider.cs
index acfab09..705b2c1 100644
--- a/src/JiShe.CollectBus.IoTDBProvider/Provider/IoTDBProvider.cs
+++ b/src/JiShe.CollectBus.IoTDBProvider/Provider/IoTDBProvider.cs
@@ -9,6 +9,7 @@ using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using System;
+using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
@@ -42,7 +43,7 @@ namespace JiShe.CollectBus.IoTDBProvider
_runtimeContext = runtimeContext;
}
-
+
///
/// 插入数据
///
@@ -143,29 +144,39 @@ namespace JiShe.CollectBus.IoTDBProvider
var timestamps = new List();
var values = new List>();
var devicePaths = new HashSet();
+ List tempColumnNames = new List();
+ tempColumnNames.AddRange(metadata.ColumnNames);
foreach (var entity in entities)
{
timestamps.Add(entity.Timestamps);
var rowValues = new List