InfluxDBClient-rs

A easy-use client to influxdb

Overview

This is an InfluxDB driver for Rust.

Status

This project has been able to run properly, most of the problems still on the type of return value, I have no solution to this problem, PR are welcome.

Todo

• Multiple write and single write.
• Get the version number and check if the database exists.
• Support query syntax.
• Support query post syntax.
• Add some easy-to-use functions.

Usage

extern crate influx_db_client;

use influx_db_client::{InfluxdbClient, Point, Points, Value, InfluxClient, Precision};

fn main() {
    let mut client = InfluxdbClient::new("http://localhost:8086", "test", "root", "root");
    client.set_write_timeout(10);
    client.set_read_timeout(10);

    let mut point = Point::new("test");
    point.add_field("somefield", Value::Integer(65));

    let mut point1 = Point::new("test2");
    point1.add_field("somefield", Value::Float(12.2));
    point1.add_tag("sometag", Value::Boolean(false));

    let mut points = Points::new(point);
    points.push(point1);

    // if Precision is None, the default is second
    // Multiple write
    let res = client.write_points(points, Some(Precision::Microseconds), None).unwrap();
    let version = client.get_version().unwrap();
    println!("{}\nversion:{}", res, version)

    // query
    let res = client.query("select * from test", None).unwrap();
    println!("{:?}", res[0].get("series").unwrap()[0].get("values"))
}

Compatibility

This is the API Document, it may apply to version 1.0 or higher.

I have tested it in version 1.0.2.

Thanks

Because influent seems to have no longer updated, and only support to the 0.9 version. I read influent.rs and influxdb-python source, and then try to write a library for 1.0+ version for support for my own use.