IoTDB时序数据库使用

简介
Apache IoTDB 是一款低成本、高性能的物联网原生时序数据库。它可以解决企业组建物联网大数据平台管理时序数据时所遇到的应用场景复杂、数据体量大、采样频率高、数据乱序多、数据处理耗时长、分析需求多样、存储与运维成本高等多种问题。
IoTDB官网

1. 连接数据库
官方提供了多种语言的连接数据库的方式和案例，这里使用的C#语言连接IoTDB

添加NuGet包 Apache.IoTDB

SessionPool sessionPool = new SessionPool("localhost", 6667, 2);
sessionPool.Open(false).Wait(); //此处必须使用wait，否则在close时后端会报错

2. 写数据

List<string> fields = new List<string>() { "temple" };
List<object> values = new List<object>() { 16.5 };
RowRecord row = new RowRecord(DateTime.UtcNow, values, fields);
await sessionPool.InsertRecordAsync("root.test.device", row);

3. 读数据
目前好像只能执行sql的方式，如果官方能增加类似Sqlsugger语法糖就更好了

var result = await sessionPool.ExecuteQueryStatementAsync("select * from root.test.device");
if (result != null)
{for (int i = 0; i < result.RowCount; i++){var row = result.Next();Console.WriteLine($"{row.Measurements[0]}:{row.Values[0]}");}
}

4. 关闭数据库连接

关闭连接，也是比较简单

await sessionPool.Close();