InfluxDB Client Libraries

Integrate your tech stack, framework, or platform with InfluxDB Client Libraries.

Why use the InfluxDB Client Libraries?

InfluxDB client libraries are language-specific packages that integrate with the InfluxDB API. Choose the languages that work best for you and your application development to work more efficiently with InfluxDB.

Read

Write

JavaScript Python Go PHP C#

const {InfluxDB, flux} = require('@influxdata/influxdb-client')

// const url = "https://us-west-2-1.aws.cloud2.influxdata.com";
const url = "http://localhost:9999";
const token = 'my-token'
const org = 'my-org'
const bucket = 'my-bucket'

const client = new InfluxDB({url: url, token: token})
const queryApi = client.getQueryApi(org)

const query = flux`from(bucket: "${bucket}") 
  |> range(start: -1d)
  |> filter(fn: (r) => r._measurement == "weatherstation")`
queryApi.queryRows(query, {
    next(row, tableMeta) {
        const o = tableMeta.toObject(row)
        console.log(`${o._time} ${o._measurement}: ${o._field}=${o._value}`)
    },
    error(error) {
        console.error(error)
        console.log('Finished ERROR')
    },
    complete() {
        console.log('Finished SUCCESS')
    },
})

const { InfluxDB, Point } = require("@influxdata/influxdb-client");

// const url = "https://us-west-2-1.aws.cloud2.influxdata.com";
const url = "http://localhost:9999";
const token = "my-token";
const org = "my-org";
const bucket = "my-bucket";

const client = new InfluxDB({ url: url, token: token });
const writeApi = client.getWriteApi(org, bucket);
const point = new Point("weatherstation")
  .tag("location", "San Francisco")
  .floatField("temperature", 23.4)
  .timestamp(new Date());

writeApi.writePoint(point);

writeApi
  .close()
  .then(() => {
    console.log("FINISHED");
  })
  .catch((e) => {
    console.error(e);
    console.log("Finished ERROR");
  });

from influxdb_client import InfluxDBClient

url = 'https://us-west-2-1.aws.cloud2.influxdata.com'
token = 'my-token'
org = 'my-org'
bucket = 'my-bucket'

with InfluxDBClient(url=url, token=token, org=org) as client:
    query_api = client.query_api()

    tables = query_api.query('from(bucket: "my-bucket") |> range(start: -1d)')

    for table in tables:
        for record in table.records:
            print(str(record["_time"]) + " - " + record.get_measurement()
                  + " " + record.get_field() + "=" + str(record.get_value()))

from datetime import datetime

from influxdb_client import WritePrecision, InfluxDBClient, Point
from influxdb_client.client.write_api import SYNCHRONOUS

url = 'https://us-west-2-1.aws.cloud2.influxdata.com'
token = 'my-token'
org = 'my-org'
bucket = 'my-bucket'

with InfluxDBClient(url=url, token=token, org=org) as client:
    p = Point("weatherstation") 
        .tag("location", "San Francisco") 
        .field("temperature", 25.9) 
        .time(datetime.utcnow(), WritePrecision.MS)

    with client.write_api(write_options=SYNCHRONOUS) as write_api:
        write_api.write(bucket=bucket, record=p)

package main

import (
	"context"
	"fmt"

	influxdb2 "github.com/influxdata/influxdb-client-go/v2"
)

func main() {
	url := "https://us-west-2-1.aws.cloud2.influxdata.com"
	token := "my-token"
	org := "my-org"
	bucket := "my-bucket"

	client := influxdb2.NewClient(url, token)
	queryAPI := client.QueryAPI(org)
	query := fmt.Sprintf(`from(bucket: "%v") |> range(start: -1d)`, bucket)
	result, err := queryAPI.Query(context.Background(), query)
	if err != nil {
		panic(err)
	}
	for result.Next() {
		record := result.Record()
		fmt.Printf("%v %v: %v=%vn", record.Time(), record.Measurement(), record.Field(), record.Value())
	}
	client.Close()
}

package main

import (
	"context"
	"time"

	influxdb2 "github.com/influxdata/influxdb-client-go/v2"
)

func main() {
	url := "https://us-west-2-1.aws.cloud2.influxdata.com"
	token := "my-token"
	org := "my-org"
	bucket := "my-bucket"

	client := influxdb2.NewClient(url, token)
	writeAPI := client.WriteAPIBlocking(org, bucket)
	p := influxdb2.NewPointWithMeasurement("weatherstation").
		AddTag("location", "San Francisco").
		AddField("temperature", 25.7).
		SetTime(time.Now())

	err := writeAPI.WritePoint(context.Background(), p)
	if err != nil {
		panic(err)
	}
	client.Close()
}

<?php

require __DIR__ . '/vendor/autoload.php';

use InfluxDB2Client;
use InfluxDB2ModelWritePrecision;

$url =  "https://us-west-2-1.aws.cloud2.influxdata.com";
$token = "my-token";
$org = "my-org";
$bucket = "my-bucket";

$client = new Client(["url" => $url, "token" => $token, "org" => $org, "precision" => WritePrecision::S]);

$queryApi = $client->createQueryApi();
$query = "from(bucket: "$bucket") |> range(start: -1d)";
$result = $queryApi->query($query);

foreach ($result as $table) {
    foreach ($table->records as $record) {
        $measurement = $record->getMeasurement();
        $field = $record->getField();
        $time = $record->getTime();
        $value = $record->getValue();
        print "$time $measurement: $field=$valuen";
    }
}

$client->close();

<?php

require __DIR__ . '/vendor/autoload.php';

use InfluxDB2Client;
use InfluxDB2ModelWritePrecision;
use InfluxDB2Point;

$url = "https://us-west-2-1.aws.cloud2.influxdata.com";
$token = "my-token";
$org = "my-org";
$bucket = "my-bucket";

$client = new Client(["url" => $url, "token" => $token, "org" => $org,
    "bucket" => $bucket, "precision" => WritePrecision::S]);

$writeApi = $client->createWriteApi();

$point = Point::measurement("weatherstation")
    ->addTag("location", "San Francisco")
    ->addField("temperature", 25.1)
    ->time(time(), WritePrecision::S);

$writeApi->write($point);
$client->close();

using System;
using System.Threading.Tasks;
using InfluxDB.Client;

namespace Examples
{
    public class QueryExample
    {
        public static async Task Main(string[] args)
        {
            var url = "https://us-west-2-1.aws.cloud2.influxdata.com";
            var token = "my-token";
            var org = "my-org";
            var bucket = "my-bucket";

            using var client = InfluxDBClientFactory.Create(url, token);

            var queryApi = client.GetQueryApi();
            var query = $"from(bucket:"{bucket}") |> range(start: -1d)";
            var tables = await queryApi.QueryAsync(query, org);
            tables.ForEach(table =>
            {
                table.Records.ForEach(record =>
                {
                    Console.WriteLine(
                        $"{record.GetTime()} {record.GetMeasurement()}: {record.GetField()}={record.GetValue()}");
                });
            });
        }
    }
}

using System;
using System.Threading.Tasks;
using InfluxDB.Client;
using InfluxDB.Client.Api.Domain;
using InfluxDB.Client.Writes;

namespace Examples
{
    public class WriteExample
    {
        public static async Task Main(string[] args)
        {
            var url = "https://us-west-2-1.aws.cloud2.influxdata.com";
            var token = "my-token";
            var org = "my-org";
            var bucket = "bucket";

            using var client = InfluxDBClientFactory.Create(url, token);
            var writeApi = client.GetWriteApiAsync();

            var point = PointData.Measurement("weatherstation")
                .Tag("location", "San Francisco")
                .Field("temperature", 25.5)
                .Timestamp(DateTime.UtcNow, WritePrecision.Ns);

             await writeApi.WritePointAsync(point, bucket, org);
        }
    }
}

Why use the InfluxDB Client Libraries?

Key capabilities

Write data

InfluxDB offers 14 client libraries that enable you to write data into your InfluxDB using Line Protocol, or data point format. Improve data ingestion efficiency using chunks of batch data or the ‘automatic retries on write failures’ feature.

Query data

Wield complete control over your data with Flux, InfluxDB’s functional data scripting language, and in combination with your preferred client library. Flux is optimized for ETL, monitoring, and alerting, with an inline planner and optimizer.

Manage your instance

Use the client library to manage your entire InfluxDB instance from within your application. Manage things like your data sources, buckets, tasks, authorizations, health checks, and more.