questdb-rs 6.1.0

QuestDB Client Library for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use std::str::FromStr;

use bigdecimal::BigDecimal;
use ndarray::arr1;
use questdb::{
    Result,
    ingress::{Sender, TimestampNanos},
};

fn main() -> Result<()> {
    let mut sender = Sender::from_conf(
        "http::addr=localhost:9000;username=foo;password=bar;protocol_version=1;",
    )?;
    let mut buffer = sender.new_buffer();
    buffer
        .table("trades_ilp_v1")?
        .symbol("symbol", "ETH-USD")?
        .symbol("side", "sell")?
        .column_f64("price", 2615.54)?
        .column_f64("amount", 0.00044)?
        .at(TimestampNanos::now())?;
    sender.flush(&mut buffer)?;

    // QuestDB server version 9.2.0 or later is required for `protocol_version=3` support.
    let mut sender2 = Sender::from_conf(
        "http::addr=localhost:9000;username=foo;password=bar;protocol_version=3;",
    )?;
    let price = BigDecimal::from_str("2615.54").unwrap();
    let mut buffer2 = sender2.new_buffer();
    buffer2
        .table("trades_ilp_v3")?
        .symbol("symbol", "ETH-USD")?
        .symbol("side", "sell")?
        .column_dec("price", &price)?
        .column_f64("amount", 0.00044)?
        .column_arr("location", &arr1(&[100.0, 100.1, 100.2]).view())?
        .at(TimestampNanos::now())?;
    sender2.flush(&mut buffer2)?;
    Ok(())
}