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.
Add iotdb to your Cargo.toml
toml
[dependencies]
iotdb = "0.0.7"
simplelog = "0.11.0"
```rust use chrono::Local;
use iotdb::*;
fn main() -> Result<(), anyhow::Error> { debug(false);
let config = iotdb::ConfigBuilder::new()
.endpoint("localhost:6667")
.user("root")
.password("root")
.time_zone("UTC+8")
.build();
// open session
let mut session = Session::connect(config)?;
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::FLOAT,
Encoding::default(),
Compressor::default(),
)?;
session.create_time_series(
"root.ln.wf01.wt01.status",
DataType::BOOLEAN,
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();
// DF (TODO)
let df = session.sql("select * from root.ln")?.to_df()?;
println!("IoTDB DF is empty: {}", df.is_empty());
session.close()?;
Ok(())
}
fn debug(enable: bool) { use simplelog::*; let mut loglevel = LevelFilter::Info; if enable { loglevel = LevelFilter::Debug; } let _ = CombinedLogger::init(vec![TermLogger::new( log_level, Default::default(), TerminalMode::Mixed, ColorChoice::Auto, )]); } ```
shell
curl -O https://archive.apache.org/dist/iotdb/0.11.2/apache-iotdb-0.11.2-bin.zip
shell
cd $IOTDB_HOME && sbin/start-server -c conf -rpc_port 6667
shell
curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh
4.Run example
```shell git clone https://github.com/francis-du/iotdb-rs.git
cargo run --example iotdb ```