This repository contains the reference C# client for the InfluxDB 2.0.
Note: Use this client library with InfluxDB 2.x and InfluxDB 1.8+ (see details). For connecting to InfluxDB 1.7 or earlier instances, use the influxdb-csharp client library.
- Supports querying using the Flux language over the InfluxDB 1.7+ REST API (
/api/v2/query endpoint) - InfluxDB 2.0 client
- Querying data using the Flux language
- Writing data using
- Line Protocol
- Data Point
- POCO
- InfluxDB 2.0 Management API client for managing
- sources, buckets
- tasks
- authorizations
- health check
- ...
The C# clients are implemented for the InfluxDB 2.0 and InfluxDB 1.7+:
| Client | Description | Documentation | Compatibility |
|---|---|---|---|
| Client | The reference C# client that allows query, write and InfluxDB 2.0 management. | readme | 2.0 |
| Client.Linq | The library supports to use a LINQ expression to query the InfluxDB. | readme | 2.0 |
| Client.Legacy | The reference C# client that allows you to perform Flux queries against InfluxDB 1.7+. | readme | 1.7+ |
The following example demonstrates how to write data to InfluxDB 2.0 and read them back using the Flux language:
Use the latest version:
dotnet add package InfluxDB.ClientInstall-Package InfluxDB.Clientusing System;
using InfluxDB.Client;
using InfluxDB.Client.Api.Domain;
using InfluxDB.Client.Core;
using InfluxDB.Client.Writes;
using Task = System.Threading.Tasks.Task;
namespace Examples
{
public static class QueriesWritesExample
{
private static readonly char[] Token = "".ToCharArray();
public static async Task Main(string[] args)
{
var influxDBClient = InfluxDBClientFactory.Create("http://localhost:8086", Token);
//
// Write Data
//
using (var writeApi = influxDBClient.GetWriteApi())
{
//
// Write by Point
//
var point = PointData.Measurement("temperature")
.Tag("location", "west")
.Field("value", 55D)
.Timestamp(DateTime.UtcNow.AddSeconds(-10), WritePrecision.Ns);
writeApi.WritePoint("bucket_name", "org_id", point);
//
// Write by LineProtocol
//
writeApi.WriteRecord("bucket_name", "org_id", WritePrecision.Ns, "temperature,location=north value=60.0");
//
// Write by POCO
//
var temperature = new Temperature {Location = "south", Value = 62D, Time = DateTime.UtcNow};
writeApi.WriteMeasurement("bucket_name", "org_id", WritePrecision.Ns, temperature);
}
//
// Query data
//
var flux = "from(bucket:\"temperature-sensors\") |> range(start: 0)";
var fluxTables = await influxDBClient.GetQueryApi().QueryAsync(flux, "org_id");
fluxTables.ForEach(fluxTable =>
{
var fluxRecords = fluxTable.Records;
fluxRecords.ForEach(fluxRecord =>
{
Console.WriteLine($"{fluxRecord.GetTime()}: {fluxRecord.GetValue()}");
});
});
influxDBClient.Dispose();
}
[Measurement("temperature")]
private class Temperature
{
[Column("location", IsTag = true)] public string Location { get; set; }
[Column("value")] public double Value { get; set; }
[Column(IsTimestamp = true)] public DateTime Time;
}
}
}The following example demonstrates how to use a InfluxDB 2.0 Management API. For further information see client documentation.
Use the latest version:
dotnet add package InfluxDB.ClientInstall-Package InfluxDB.Clientusing System.Collections.Generic;
using InfluxDB.Client;
using InfluxDB.Client.Api.Domain;
using Task = System.Threading.Tasks.Task;
namespace Examples
{
public static class ManagementExample
{
private static readonly char[] Token = "".ToCharArray();
public static async Task Main(string[] args)
{
var influxDBClient = InfluxDBClientFactory.Create("http://localhost:8086", Token);
//
// Create bucket "iot_bucket" with data retention set to 3,600 seconds
//
var retention = new BucketRetentionRules(BucketRetentionRules.TypeEnum.Expire, 3600);
var bucket = await influxDBClient.GetBucketsApi().CreateBucketAsync("iot_bucket", retention, "org_id");
//
// Create access token to "iot_bucket"
//
var resource = new PermissionResource{Id = bucket.Id, OrgID = "org_id",Type = PermissionResource.TypeEnum.Buckets};
// Read permission
var read = new Permission{Resource = resource, Action = Permission.ActionEnum.Read};
// Write permission
var write = new Permission{Resource = resource, Action = Permission.ActionEnum.Write};
var authorization = await influxDBClient.GetAuthorizationsApi()
.CreateAuthorizationAsync("org_id", new List<Permission> {read, write});
//
// Created token that can be use for writes to "iot_bucket"
//
var token = authorization.Token;
influxDBClient.Dispose();
}
}
}InfluxDB 1.8.0 introduced forward compatibility APIs for InfluxDB 2.0. This allow you to easily move from InfluxDB 1.x to InfluxDB 2.0 Cloud or open source.
The following forward compatible APIs are available:
| API | Endpoint | Description |
|---|---|---|
| QueryApi.cs | /api/v2/query | Query data in InfluxDB 1.8.0+ using the InfluxDB 2.0 API and Flux (endpoint should be enabled by flux-enabled option) |
| WriteApi.cs | /api/v2/write | Write data to InfluxDB 1.8.0+ using the InfluxDB 2.0 API |
| HealthAsync | /health | Check the health of your InfluxDB instance |
For detail info see InfluxDB 1.8 example.
The following example demonstrates querying using the Flux language.
Use the latest version:
dotnet add package InfluxDB.Client.FluxInstall-Package InfluxDB.Client.Fluxusing System;
using InfluxDB.Client.Flux;
namespace Examples
{
public static class FluxExample
{
public static void Run()
{
var fluxClient = FluxClientFactory.Create("http://localhost:8086/");
var fluxQuery = "from(bucket: \"telegraf\")\n"
+ " |> filter(fn: (r) => (r[\"_measurement\"] == \"cpu\" AND r[\"_field\"] == \"usage_system\"))"
+ " |> range(start: -1d)"
+ " |> sample(n: 5, pos: 1)";
fluxClient.QueryAsync(fluxQuery, (cancellable, record) =>
{
// process the flux query records
Console.WriteLine(record.GetTime() + ": " + record.GetValue());
},
(error) =>
{
// error handling while processing result
Console.WriteLine(error.ToString());
}, () =>
{
// on complete
Console.WriteLine("Query completed");
}).GetAwaiter().GetResult();
}
}
}If you would like to contribute code you can do through GitHub by forking the repository and sending a pull request into the master branch.
The InfluxDB 2.0 Clients are released under the MIT License.