wangbincumt/Influxdb.BulkInsert

Influxdb asynchronous, fast and bulk insert components.Using HTTP or UDP protocol.Influxdb 异步、快速、批量插入组件，支持http和udp协议。

Influxdb.BulkInsert

Influxdb 异步、快速、批量插入组件，支持http和udp协议，目前不支持https。

开始

1.HTTP

var insert = new InfluxHttpBulkInsert(new InfluxConnectionSetting() { Server = "192.168.10.110", Port = 8086,Database = "kong",BitchSize = 5000});
var processor = new InfluxBulkInsertProcessor(insert);

processor.Open();
for (int i = 0; i < 1000; i++)
{
    processor.Write($"test,type='cpu' value=1 {InfluxdbTimeGen.GenNanosecond()}");
}

Console.WriteLine("Complete");
Console.Read();
processor.Close();

2.UDP

var insert = new InfluxUdpBulkInsert(new InfluxConnectionSetting() { Server = "192.168.10.110", Port = 8089,BitchSize = 10});
var processor = new InfluxBulkInsertProcessor(insert);

processor.Open();
for (int i = 0; i < 1000; i++)
{
    processor.Write($"test,type='cpu' value={i} {InfluxdbTimeGen.GenNanosecond()}");
}
Console.WriteLine("Complete");
Console.Read();
processor.Close();

使用规范

1.写入的数据末尾字符不得带换行 ”\n“

这种不被允许:

test,type='cpu' value=1\n
test,type='cpu' value=1\ntest,type='cpu' value=1\n

这种允许：

test,type='cpu' value=1
test,type='cpu' value=1\ntest,type='cpu' value=1

2.写入数据必须带上时间戳

因为发送数据是按批次发送，如果批次的数据数量大于1（BitchSize）,那么数据是合并发送的，这时需要每条数据都带上时间戳，不然数据将会被覆盖。可以使用 InfluxdbTimeGen.GenNanosecond()来生成纳秒时间戳，时间戳必须为纳秒。

3.数据格式

<measurement>,<tags> <fields> <time>

示例：

test,type='cpu' value=1 1539076079817999232
test,type='cpu' value=1 1539076079817999232\ntest,type='cpu' value=1 1539076079817999232