influx-client 0.3.0

A Rust library to interact with InfluxDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

# influx_client
[![crates-badge](https://img.shields.io/crates/v/influx_client?style=for-the-badge)](https://crates.io/crates/influx_client) [![docs-badge](https://img.shields.io/docsrs/influx-client/latest?style=for-the-badge)](https://docs.rs/influx_client)

A Rust library to interact with [InfluxDB](https://www.influxdata.com/) databases.
It is still early in development, so expect bugs and missing features.

## Things that work

- Writing data to a bucket
- Querying data in a certain time range (only relative so far)
- Using filters in queries

## Examples

Reading from a bucket:

```rust
use influx_client::{
    Client, Precision, WriteQuery,
};

fn main() {
    let client = Client::from_env("http://localhost:8086").expect("INFLUXDB_TOKEN not set");
    let mut tags = BTreeMap::new();
    tags.insert("t1", "v1");
    tags.insert("t2", "v2");
    let data = WriteQuery {
        name: "test",
        tags,
        field_name: "i",
        value: 42,
        timestamp: None,
    };

    client.insert("home", "home", Precision::ms, data);
}
```

Writing to a bucket:

```rust
use std::collections::BTreeMap;

use influx_client::{
    flux::functions::{NumericFilter, Range, StringFilter},
    Client, Precision, ReadQuery,
};

fn main() {
    let client = Client::from_env("http://localhost:8086").expect("INFLUXDB_TOKEN not set");

    let q = ReadQuery::new("home")
        .range(Range::new(Some((-12, Precision::h)), None))
        .filter(StringFilter::Eq("_measurement", "test"))
        .filter(NumericFilter::Lt("_value", 99));

    println!("{}", client.get("home", q).unwrap());
}
```