influxdb 0.8.0 - Docs.rs

Pull requests are always welcome. See Contributing and Code of Conduct. For a list of past changes, see CHANGELOG.md.

Currently Supported Features

Reading and writing to InfluxDB
Optional Serde support for deserialization
Running multiple queries in one request (e.g. SELECT * FROM weather_berlin; SELECT * FROM weather_london)
Writing single or multiple measurements in one request (e.g. WriteQuery or Vec<WriteQuery> argument)
Authenticated and unauthenticated connections
async/await support
#[derive(InfluxDbWriteable)] derive macro for writing / reading into structs
GROUP BY support
Tokio and async-std support (see example below) or available backends
Swappable HTTP backends (see below)

Quickstart

Add the following to your Cargo.toml

influxdb = { version = "0.8.0", features = ["derive"] }

For an example with using Serde deserialization, please refer to serde_integration

use chrono::{DateTime, Utc};
use influxdb::{Client, Error, InfluxDbWriteable, ReadQuery, Timestamp};

#[tokio::main]
async fn main() -> Result<(), Error> {
    // Connect to db `test` on `http://localhost:8086`
    let client = Client::new("http://localhost:8086", "test");

    #[derive(InfluxDbWriteable)]
    struct WeatherReading {
        time: DateTime<Utc>,
        humidity: i32,
        #[influxdb(tag)]
        wind_direction: String,
    }

    // Let's write some data into a measurement called `weather`
    let weather_readings = vec![
        WeatherReading {
            time: Timestamp::Hours(1).try_into().unwrap(),
            humidity: 30,
            wind_direction: String::from("north"),
        }
        .try_into_query("weather")
        .unwrap(),
        WeatherReading {
            time: Timestamp::Hours(2).try_into().unwrap(),
            humidity: 40,
            wind_direction: String::from("west"),
        }
        .try_into_query("weather")
        .unwrap(),
    ];

    client.query(weather_readings).await?;

    // Read back all records
    let read_query = ReadQuery::new("SELECT * FROM weather");

    let read_result = client.query(read_query).await?;
    println!("{}", read_result);
    Ok(())
}

For further examples, check out the integration tests in tests/integration_tests.rs in the repository.

Choice of HTTP backend

To communicate with InfluxDB, you can choose the HTTP backend to be used configuring the appropriate feature. We recommend sticking with the default reqwest-based client, unless you really need async-std compatibility.

hyper (through reqwest, used by default), with rustls

influxdb = { version = "0.8.0", features = ["derive"] }

hyper (through reqwest), with native TLS (OpenSSL)

influxdb = { version = "0.8.0", default-features = false, features = ["derive", "serde", "native-tls"] }

hyper (through reqwest), with vendored native TLS (OpenSSL)

influxdb = { version = "0.8.0", default-features = false, features = ["derive", "serde", "native-tls-vendored"] }

License

@ 2020-2026 Gero Gerke, msrd0 and contributors.