Unofficial InfluxDB Driver for Rust
Pull requests are always welcome. See Contributing and Code of Conduct. For a list of past changes, see CHANGELOG.md.
- 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.
WriteQueryorVec<WriteQuery>argument) - Authenticated and unauthenticated connections
async/awaitsupport#[derive(InfluxDbWriteable)]derive macro for writing / reading into structsGROUP BYsupport- Tokio and async-std support (see example below) or available backends
- Swappable HTTP backends (see below)
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 `https://localhost:8086`
let client = Client::new("https://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?;
// Read back all records
let read_query = ReadQuery::new("SELECT * FROM weather");
let read_result = client.query(read_query).await?;
println!("{}", read_result);
Ok(