Unofficial InfluxDB Driver for Rust

This library is a work in progress. This means a feature you might need is not implemented yet or could be handled better.

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

toml influxdb = { version = "0.6", features = ["derive"] }

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

```rust use influxdb::{Client, Query, Timestamp, ReadQuery}; use influxdb::InfluxDbWriteable; use chrono::{DateTime, Utc};

[tokio::main]

// or #[async_std::main] if you prefer async fn main() { // 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).into(),
        humidity: 30,
        wind_direction: String::from("north"),
    }.into_query("weather"),
    WeatherReading {
        time: Timestamp::Hours(2).into(),
        humidity: 40,
        wind_direction: String::from("west"),
    }.into_query("weather"),
);

let write_result = client
    .query(weather_readings)
    .await;
assert!(write_result.is_ok(), "Write result was not okay");

// Let's see if the data we wrote is there
let read_query = ReadQuery::new("SELECT * FROM weather");

let read_result = client.query(read_query).await;
assert!(read_result.is_ok(), "Read result was not ok");
println!("{}", read_result.unwrap());

} ```

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 toml influxdb = { version = "0.6", features = ["derive"] }

• hyper (through reqwest), with native TLS (OpenSSL) toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "reqwest-client"] }

• hyper (through surf), use this if you need tokio 0.2 compatibility toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "curl-client"] }

• curl, using libcurl toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "curl-client"] }
• async-h1 with native TLS (OpenSSL) toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "h1-client"] }
• async-h1 with rustls toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "h1-client-rustls"] }
• WebAssembly's window.fetch, via web-sys and wasm-bindgen toml influxdb = { version = "0.6", default-features = false, features = ["derive", "use-serde", "wasm-client"] }

License

@ 2020 Gero Gerke and contributors.