Overview

Status

Usage

Use

[dependencies]influx_db_client = "^0.5.0"

http

use influx_db_client::{Client,Point,Points,Value,Precision, point, points};use tokio;fnmain(){// default with "http://127.0.0.1:8086", db with "test"let client =Client::default().set_authentication("root","root");let point =point!("test1").add_field("foo","bar").add_field("integer",11).add_field("float",22.3).add_field("'boolean'",false);let point1 =Point::new("test1").add_tag("tags","\\\"fda").add_tag("number",12).add_tag("float",12.6).add_field("fd","'3'").add_field("quto","\\\"fda").add_field("quto1","\"fda");let points =points!(point1, point);    tokio::runtime::Runtime::new().unwrap().block_on(asyncmove{// if Precision is None, the default is second// Multiple write        client.write_points(points,Some(Precision::Seconds),None).await.unwrap();// query, it's type is Option<Vec<Node>>let res = client.query("select * from test1",None).await.unwrap();println!("{:?}", res.unwrap()[0].series)});}

udp

use influx_db_client::{UdpClient,Point,Value, point};fnmain(){letmut udp =UdpClient::new("127.0.0.1:8089");    udp.add_host("127.0.0.1:8090");let point =point!("test").add_field("foo",Value::String(String::from("bar")));    udp.write_point(point).unwrap();}

Compatibility

Thanks