Pipes in Rust¶

use meerschaum::{Frame, InstanceConnector, Pipe, SqlConnector, SyncOptions};
use meerschaum::kernel::value::Value as Cell;
use meerschaum::sql::uri::ConnectionSpec;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let spec = ConnectionSpec::from_uri("sqlite:///demo.db", Some("demo"), None)?;
    let conn = SqlConnector::connect("demo", spec).await?;
    let pipe = Pipe::builder("plugin:manual", "readings")
        .instance("sql:demo")
        .build()?;
    let rows = Frame::from_object_columns(vec![
        ("id".into(), vec![Cell::Int(1)]),
        ("temperature".into(), vec![Cell::Float(21.5)]),
    ])?;
    let result = InstanceConnector::sync_pipe(
        &conn, &pipe, rows, &SyncOptions::default(),
    ).await;
    println!("{result:?}");
    Ok(())
}