Overview
IoTDB (Internet of Things Database) is a data management system for time series data, which can provide users specific
services, such as, data collection, storage and analysis. Due to its light weight structure, high performance and usable
features together with its seamless integration with the Hadoop and Spark ecology, IoTDB meets the requirements of
massive dataset storage, high throughput data input, and complex data analysis in the industrial IoT field.
How to use
Add iotdb
to your Cargo.toml
[dependencies]
iotdb = "0.0.6"
Example
use chrono::Local;
use thrift::Error;
use iotdb::common::{Compressor, DataType, Encoding};
use iotdb::{ConfigBuilder, Session};
fn main() -> Result<(), Error> {
let config = ConfigBuilder::new()
.endpoint("127.0.0.1", "6667")
.user("root")
.password("root")
.time_zone("UTC+8")
.build();
let mut session = Session::new(config).open()?;
println!("time_zone: {}", session.time_zone()?);
session.delete_storage_group("root.ln")?;
session.set_storage_group("root.ln")?;
session.create_time_series(
"root.ln.wf01.wt01.temperature",
DataType::INT64,
Encoding::default(),
Compressor::default(),
)?;
session.create_time_series(
"root.ln.wf01.wt01.humidity",
DataType::INT64,
Encoding::default(),
Compressor::default(),
)?;
let now = Local::now().timestamp_millis();
session.sql(
format!(
"INSERT INTO root.ln.wf01.wt01(timestamp,status) values({},true)",
now
)
.as_str(),
)?;
session.sql(
format!(
"INSERT INTO root.ln.wf01.wt01(timestamp,status) values({},false)",
now + 1000
)
.as_str(),
)?;
session.sql(
format!(
"INSERT INTO root.ln.wf01.wt01(timestamp,status,temperature) values({},false,18.36)",
now + 2000
)
.as_str(),
)?;
session.sql(
format!(
"INSERT INTO root.ln.wf01.wt01(timestamp,status,temperature) values({},true,32.23)",
now + 3000
)
.as_str(),
)?;
session.sql("select * from root.ln")?.show();
session.close()?;
Ok(())
}
Run example
- Download the package from here
curl -O https://archive.apache.org/dist/iotdb/0.11.2/apache-iotdb-0.11.2-bin.zip
- Install and start iotdb server
cd $IOTDB_HOME && sbin/start-server -c conf -rpc_port 6667
- Install rust toolchain from here
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
4.Run example
git clone https://github.com/francis-du/iotdb-rs.git
cargo run --example main
LICENSE
Apache License 2.0