# Influxdb2.Client

**Repository Path**: loveteam/Influxdb2.Client

## Basic Information

- **Project Name**: Influxdb2.Client
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2021-04-27
- **Last Updated**: 2024-09-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Influxdb2.Client
Influxdb2读写性能最快的dotnet客户端，读写性能为官方客户端库的180%(本机mock Influxdb服务器，完整的读写流程)

> 
```
dotnet add package Influxdb2.Client
```
### 服务注册
```
services.AddInfuxdb(o =>
{
    o.Host = new Uri("http://localhost:8086");
    o.Token = "base64 token value";
    o.DefaultOrg = "my-org";
    o.DefaultBucket = "my-bucket";
});
```

### 服务获取
```
MyService(IInfuxdb infuxdb)
{
}
```
###

### 写入数据
```
var book = new Book();
await infuxdb.WriteAsync(book);
```
或者
```
var book = new PointBuilder("Book")
    .SetTag("key", "value")
    .SetField("field", "value")
    .Build();
await infuxdb.WriteAsync(book);
```

数据属性需要ColumnType标记
```
class Book
{
    [ColumnType(ColumnType.Tag)]
    public string Serie { get; set; }


    [ColumnType(ColumnType.Field)]
    public string Name { get; set; }


    [ColumnType(ColumnType.Field)]
    public double? Price { get; set; }


    [ColumnType(ColumnType.Field)]
    public bool? SpecialOffer { get; set; }


    [ColumnType(ColumnType.Timestamp)]
    public DateTimeOffset? CreateTime { get; set; } 
}
```

### 读取数据

```
var flux = Flux
    .From(defaultBucket)
    .Range("-3d")
    .Filter(FnBody.R.MeasurementEquals($"{nameof(Book)}"))
    .Pivot()
    .Sort(Columns.Time, desc: true)
    .Limit(10)
    ;

var tables = await infuxdb.QueryAsync(flux);
// 可以映射为任意模型（未必是Book)
var books = tables.Single().ToModels<Book>();
```