Salvini.IoTDB 2.13.970

Salvini TimeSeries Client

采用 Apache IoTDB 实现，封装类似 PI、eDNA 传统实时历史数据库访问接口风格 采用 MongoDB 连接字符串格式，iotdb://root:admin#123@192.168.0.11:6667/database=lz

生成 rpc.thrift

https://github.com/apache/iotdb/blob/master/thrift/src/main/thrift/rpc.thrift

thrif -r -gen netstd rpc.thrift 

调用样例

using Salvini.IoTDB;

class Program
{
    static async Task Main(string[] args)
    {
        using var client1 = TimeSeriesClient.CreateInstance("iotdb://root:admin#123@192.168.145.120:6667/database=kylin");
        using var client2 = TimeSeriesClient.CreateInstance("iotdb://root:admin#123@192.168.145.120:6667/database=KylinAGC");

        await client2.InitializeAsync(new List<(string Tag, string Type, string Unit, string Desc)> { ("MW", "AI", "兆瓦", "机组负荷") });
        var archive1 = await client1.HistoryAsync(new List<string> { "AO_PL_RATE_PV" }, new DateTime(2022, 8, 4).AddHours(14), new DateTime(2022, 8, 4).AddHours(15), 4);
        await client2.BulkWriteAsync("AO_PL_RATE_PV", archive1["AO_PL_RATE_PV"]);
        var archive2 = await client2.HistoryAsync(new List<string> { "AO_PL_RATE_PV" }, new DateTime(2022, 8, 4).AddHours(14), new DateTime(2022, 8, 4).AddHours(15), 4);
    }
}

Version 2.13.970.0

[+] 解决 InitializeAsync 无法更新测点信息BUG [+] 去掉对 ApacheIoTDB 访问接口的直接公开，仅公开 TimeSeriesClient 对象 [-] Session, Client, ClientPool ...