Salvini.IoTDB 2.13.970.817

Salvini IoTDB

生成 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)
  {
    var session = new Session(password: "admin#123", host: "192.168.0.11");
    await session.OpenAsync();
    using var ds = await session.ExecuteQueryStatementAsync("select MW from root.lz limit 10");
    var matrix = ds.ReadAsMatrix();

    for (var i = 0; i < matrix.Length / matrix.Rank; i++)
    {
      for (var j = 0; j < matrix.Rank; j++)
      {
        var val = string.Empty;
        if (i == 0) val = (string)matrix[i, j];
        else if (j == 0) val = ((DateTime)matrix[i, j]).ToString("yyyy-MM-dd HH:mm:ss");
        else val = ((double)matrix[i, j]).ToString("f6").PadLeft(((string)matrix[0, j]).Length, (char)32);

        Console.Write($"{val}{(j != matrix.Rank - 1 ? '\t' : '\0')}");
      }
      Console.WriteLine();
    }
  }
}

Salvini TimeSeries Client

采用类似mongodb连接字符串格式，iotdb://root:admin#123@192.168.0.11:6667/database=lz

调用样例

using Salvini;

class Program
{
  static async Task Main(string[] args)
  {

    var client = TimeSeriesClient.CreateInstance("iotdb://root:admin#123@192.168.0.11:6667/database=lz");
    await client.OpenAsync();
    var archive = await client.ArchiveAsync("MW", new DateTime(2021, 03, 02), new DateTime(2021, 03, 02).AddHours(1), 8);
    foreach (var ln in archive)
    {
      Console.WriteLine(ln);
    }
    await client.CloseAsync();
  }
}