17 releases

0.7.2 Feb 14, 2024
0.7.1 Sep 8, 2023
0.7.0 Jul 3, 2023
0.6.0 Mar 4, 2023
0.0.3 Jul 14, 2019

#70 in Database interfaces

Download history 1618/week @ 2024-08-13 1583/week @ 2024-08-20 2116/week @ 2024-08-27 1845/week @ 2024-09-03 1805/week @ 2024-09-10 1824/week @ 2024-09-17 2203/week @ 2024-09-24 1743/week @ 2024-10-01 1558/week @ 2024-10-08 2167/week @ 2024-10-15 2017/week @ 2024-10-22 2245/week @ 2024-10-29 1827/week @ 2024-11-05 2184/week @ 2024-11-12 2062/week @ 2024-11-19 2134/week @ 2024-11-26

8,660 downloads per month
Used in 28 crates (21 directly)

MIT license

82KB
1.5K SLoC


rust-influxdb

Unofficial InfluxDB Driver for Rust

Build Status Coverage Report Documentation Status Build with Rust Minimum Rust Version: 1.65

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

influxdb = { version = "0.7.2", 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]
// or #[async_std::main] if you prefer
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).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"),
    ];

    client.query(weather_readings).await?;

    // 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?;
    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.7.2", features = ["derive"] }
    
  • hyper (through reqwest), with native TLS (OpenSSL)

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

    influxdb = { version = "0.7.2", default-features = false,features = ["derive", "use-serde", "hyper-client"] }
    
  • curl, using libcurl

    influxdb = { version = "0.7.2", default-features = false,features = ["derive", "use-serde", "curl-client"] }
    
  • async-h1 with native TLS (OpenSSL)

    influxdb = { version = "0.7.2", default-features = false,features = ["derive", "use-serde", "h1-client"] }
    
  • async-h1 with rustls

    influxdb = { version = "0.7.2", default-features = false,features = ["derive", "use-serde", "h1-client-rustls"] }
    
  • WebAssembly’s window.fetch, via web-sys and wasm-bindgen

    influxdb = { version = "0.7.2", default-features = false,features = ["derive", "use-serde", "wasm-client"] }
    

License

License: MIT

@ 2020 Gero Gerke and contributors.

Dependencies

~5–25MB
~401K SLoC