From 2e32ebe7f8fdccf47e7c3d98742e04803cb54fe9 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:12:55 +0800 Subject: [PATCH 01/11] docs: case of sml put line --- .../examples/schemaless_insert_line.rs | 79 +++++++++++++++++++ 1 file changed, 79 insertions(+) create mode 100644 docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs new file mode 100644 index 0000000000..8fe9bf40ff --- /dev/null +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs @@ -0,0 +1,79 @@ +use taos_query::common::SchemalessPrecision; +use taos_query::common::SchemalessProtocol; +use taos_query::common::SmlDataBuilder; + +use crate::AsyncQueryable; +use crate::AsyncTBuilder; +use crate::TaosBuilder; + +async fn put_line() -> anyhow::Result<()> { + // std::env::set_var("RUST_LOG", "taos=trace"); + std::env::set_var("RUST_LOG", "taos=debug"); + pretty_env_logger::init(); + + let dsn = + std::env::var("TDENGINE_ClOUD_DSN").unwrap_or("http://localhost:6041".to_string()); + log::debug!("dsn: {:?}", &dsn); + + let client = TaosBuilder::from_dsn(dsn)?.build().await?; + + let db = "demo_schemaless_ws"; + + client.exec(format!("drop database if exists {db}")).await?; + + client + .exec(format!("create database if not exists {db}")) + .await?; + + let data = [ + "measurement,host=host1 field1=2i,field2=2.0 1577837300000", + "measurement,host=host1 field1=2i,field2=2.0 1577837400000", + "measurement,host=host1 field1=2i,field2=2.0 1577837500000", + "measurement,host=host1 field1=2i,field2=2.0 1577837600000", + ] + .map(String::from) + .to_vec(); + + // demo with all fields + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Line) + .precision(SchemalessPrecision::Millisecond) + .data(data.clone()) + .ttl(1000) + .req_id(100u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo omit ttl by default + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Line) + .precision(SchemalessPrecision::Millisecond) + .data(data.clone()) + .req_id(101u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo omit ttl and req_id by default + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Line) + .precision(SchemalessPrecision::Millisecond) + .data(data.clone()) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo omit precision by default + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Line) + .data(data) + .req_id(103u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + client.exec(format!("drop database if exists {db}")).await?; + + Ok(()) +} From 14a76427f308ae90a9be8b3604cb42c8f2fb56d5 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:16:00 +0800 Subject: [PATCH 02/11] docs: case put sml telnet --- .../examples/schemaless_insert_telnet.rs | 82 +++++++++++++++++++ 1 file changed, 82 insertions(+) create mode 100644 docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs new file mode 100644 index 0000000000..c9a71c33c7 --- /dev/null +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs @@ -0,0 +1,82 @@ +use taos_query::common::SchemalessPrecision; +use taos_query::common::SchemalessProtocol; +use taos_query::common::SmlDataBuilder; + +use crate::AsyncQueryable; +use crate::AsyncTBuilder; +use crate::TaosBuilder; + +async fn put_telnet() -> anyhow::Result<()> { + // std::env::set_var("RUST_LOG", "taos=trace"); + std::env::set_var("RUST_LOG", "taos=debug"); + pretty_env_logger::init(); + let dsn = + std::env::var("TDENGINE_ClOUD_DSN").unwrap_or("http://localhost:6041".to_string()); + log::debug!("dsn: {:?}", &dsn); + + let client = TaosBuilder::from_dsn(dsn)?.build().await?; + + let db = "test_schemaless_ws"; + + client.exec(format!("drop database if exists {db}")).await?; + + client + .exec(format!("create database if not exists {db}")) + .await?; + + + let data = [ + "meters.current 1648432611249 10.3 location=California.SanFrancisco group=2", + "meters.current 1648432611250 12.6 location=California.SanFrancisco group=2", + "meters.current 1648432611249 10.8 location=California.LosAngeles group=3", + "meters.current 1648432611250 11.3 location=California.LosAngeles group=3", + "meters.voltage 1648432611249 219 location=California.SanFrancisco group=2", + "meters.voltage 1648432611250 218 location=California.SanFrancisco group=2", + "meters.voltage 1648432611249 221 location=California.LosAngeles group=3", + "meters.voltage 1648432611250 217 location=California.LosAngeles group=3", + ] + .map(String::from) + .to_vec(); + + // demo with all fields + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Telnet) + .precision(SchemalessPrecision::Millisecond) + .data(data.clone()) + .ttl(1000) + .req_id(200u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default precision + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Telnet) + .data(data.clone()) + .ttl(1000) + .req_id(201u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default ttl + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Telnet) + .data(data.clone()) + .req_id(202u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default req_id + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Telnet) + .data(data.clone()) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + client.exec(format!("drop database if exists {db}")).await?; + + Ok(()) +} \ No newline at end of file From c405051bb3d5bb21223db78cf93114430ce3f5a6 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:16:59 +0800 Subject: [PATCH 03/11] docs: update put line --- .../rust/nativeexample/examples/schemaless_insert_line.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs index 8fe9bf40ff..f4ffc78c54 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs @@ -45,7 +45,7 @@ async fn put_line() -> anyhow::Result<()> { .build()?; assert_eq!(client.put(&sml_data).await?, ()); - // demo omit ttl by default + // demo with default ttl let sml_data = SmlDataBuilder::default() .db(db.to_string()) .protocol(SchemalessProtocol::Line) @@ -55,7 +55,7 @@ async fn put_line() -> anyhow::Result<()> { .build()?; assert_eq!(client.put(&sml_data).await?, ()); - // demo omit ttl and req_id by default + // demo with default ttl and req_id let sml_data = SmlDataBuilder::default() .db(db.to_string()) .protocol(SchemalessProtocol::Line) @@ -64,7 +64,7 @@ async fn put_line() -> anyhow::Result<()> { .build()?; assert_eq!(client.put(&sml_data).await?, ()); - // demo omit precision by default + // demo with default precision let sml_data = SmlDataBuilder::default() .db(db.to_string()) .protocol(SchemalessProtocol::Line) From bec5790c6c8b0dda8c0e23925b95a7d46ae2ac76 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:17:20 +0800 Subject: [PATCH 04/11] docs: update put telnet format --- .../rust/nativeexample/examples/schemaless_insert_telnet.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs index c9a71c33c7..2f7c20d7b5 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs @@ -79,4 +79,4 @@ async fn put_telnet() -> anyhow::Result<()> { client.exec(format!("drop database if exists {db}")).await?; Ok(()) -} \ No newline at end of file +} From 20bb69cc16b227defe0a5f28012eeea5235d884a Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:19:23 +0800 Subject: [PATCH 05/11] docs: case put sml json --- .../examples/schemaless_insert_json.rs | 75 +++++++++++++++++++ 1 file changed, 75 insertions(+) create mode 100644 docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs new file mode 100644 index 0000000000..1a0e219462 --- /dev/null +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs @@ -0,0 +1,75 @@ +use taos_query::common::SchemalessPrecision; +use taos_query::common::SchemalessProtocol; +use taos_query::common::SmlDataBuilder; + +use crate::AsyncQueryable; +use crate::AsyncTBuilder; +use crate::TaosBuilder; + +async fn put_json() -> anyhow::Result<()> { + // std::env::set_var("RUST_LOG", "taos=trace"); + std::env::set_var("RUST_LOG", "taos=debug"); + pretty_env_logger::init(); + let dsn = + std::env::var("TDENGINE_ClOUD_DSN").unwrap_or("http://localhost:6041".to_string()); + log::debug!("dsn: {:?}", &dsn); + + let client = TaosBuilder::from_dsn(dsn)?.build().await?; + + let db = "demo_schemaless_ws"; + + client.exec(format!("drop database if exists {db}")).await?; + + client + .exec(format!("create database if not exists {db}")) + .await?; + + // SchemalessProtocol::Json + let data = [ + r#"[{"metric": "meters.current", "timestamp": 1681345954000, "value": 10.3, "tags": {"location": "California.SanFrancisco", "groupid": 2}}, {"metric": "meters.voltage", "timestamp": 1648432611249, "value": 219, "tags": {"location": "California.LosAngeles", "groupid": 1}}, {"metric": "meters.current", "timestamp": 1648432611250, "value": 12.6, "tags": {"location": "California.SanFrancisco", "groupid": 2}}, {"metric": "meters.voltage", "timestamp": 1648432611250, "value": 221, "tags": {"location": "California.LosAngeles", "groupid": 1}}]"# + ] + .map(String::from) + .to_vec(); + + // demo with all fields + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Json) + .precision(SchemalessPrecision::Millisecond) + .data(data.clone()) + .ttl(1000) + .req_id(300u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default precision + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Json) + .data(data.clone()) + .ttl(1000) + .req_id(301u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default ttl + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Json) + .data(data.clone()) + .req_id(302u64) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + // demo with default req_id + let sml_data = SmlDataBuilder::default() + .db(db.to_string()) + .protocol(SchemalessProtocol::Json) + .data(data.clone()) + .build()?; + assert_eq!(client.put(&sml_data).await?, ()); + + client.exec(format!("drop database if exists {db}")).await?; + + Ok(()) +} From ae37c254ad6bcb42e5b77723f4c855e99dffdfc6 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:19:51 +0800 Subject: [PATCH 06/11] docs: update put telnet db name --- .../rust/nativeexample/examples/schemaless_insert_telnet.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs index 2f7c20d7b5..944216338e 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs @@ -16,7 +16,7 @@ async fn put_telnet() -> anyhow::Result<()> { let client = TaosBuilder::from_dsn(dsn)?.build().await?; - let db = "test_schemaless_ws"; + let db = "demo_schemaless_ws"; client.exec(format!("drop database if exists {db}")).await?; From c43cdd4faf4682a5ec3e95b27276224ceda45982 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:21:41 +0800 Subject: [PATCH 07/11] docs: add sml.mdx --- docs/zh/07-develop/03-insert-data/_rust_schemaless.mdx | 3 +++ 1 file changed, 3 insertions(+) create mode 100644 docs/zh/07-develop/03-insert-data/_rust_schemaless.mdx diff --git a/docs/zh/07-develop/03-insert-data/_rust_schemaless.mdx b/docs/zh/07-develop/03-insert-data/_rust_schemaless.mdx new file mode 100644 index 0000000000..a26613bd15 --- /dev/null +++ b/docs/zh/07-develop/03-insert-data/_rust_schemaless.mdx @@ -0,0 +1,3 @@ +```rust +{{#include docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs}} +``` From 88e1e5145ed17d54572da44d69045b99327aa797 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:23:27 +0800 Subject: [PATCH 08/11] docs: update rust.mdx --- docs/zh/08-connector/26-rust.mdx | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/docs/zh/08-connector/26-rust.mdx b/docs/zh/08-connector/26-rust.mdx index eeb93a6558..d4ca25be81 100644 --- a/docs/zh/08-connector/26-rust.mdx +++ b/docs/zh/08-connector/26-rust.mdx @@ -10,6 +10,7 @@ import TabItem from '@theme/TabItem'; import Preparation from "./_preparation.mdx" import RustInsert from "../07-develop/03-insert-data/_rust_sql.mdx" import RustBind from "../07-develop/03-insert-data/_rust_stmt.mdx" +import RustSml from "../07-develop/03-insert-data/_rust_schemaless.mdx" import RustQuery from "../07-develop/04-query-data/_rust.mdx" [![Crates.io](https://img.shields.io/crates/v/taos)](https://crates.io/crates/taos) ![Crates.io](https://img.shields.io/crates/d/taos) [![docs.rs](https://img.shields.io/docsrs/taos)](https://docs.rs/taos) @@ -230,6 +231,10 @@ async fn demo(taos: &Taos, db: &str) -> Result<(), Error> { +#### Schemaless 写入 + + + ### 查询数据 From 13ea24312dccaea506a323dd228de05d19571253 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:30:34 +0800 Subject: [PATCH 09/11] docs: add mdx en --- docs/en/07-develop/03-insert-data/_rust_schemaless.mdx | 3 +++ 1 file changed, 3 insertions(+) create mode 100644 docs/en/07-develop/03-insert-data/_rust_schemaless.mdx diff --git a/docs/en/07-develop/03-insert-data/_rust_schemaless.mdx b/docs/en/07-develop/03-insert-data/_rust_schemaless.mdx new file mode 100644 index 0000000000..a26613bd15 --- /dev/null +++ b/docs/en/07-develop/03-insert-data/_rust_schemaless.mdx @@ -0,0 +1,3 @@ +```rust +{{#include docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs}} +``` From d3540a7502db8b9a1924fd18565a532c6fa6cf64 Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Sun, 23 Apr 2023 10:31:53 +0800 Subject: [PATCH 10/11] docs: update mdx en --- docs/en/14-reference/03-connector/06-rust.mdx | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/docs/en/14-reference/03-connector/06-rust.mdx b/docs/en/14-reference/03-connector/06-rust.mdx index ad522e9d2b..597a9b0f52 100644 --- a/docs/en/14-reference/03-connector/06-rust.mdx +++ b/docs/en/14-reference/03-connector/06-rust.mdx @@ -11,6 +11,7 @@ import TabItem from '@theme/TabItem'; import Preparition from "./_preparation.mdx" import RustInsert from "../../07-develop/03-insert-data/_rust_sql.mdx" import RustBind from "../../07-develop/03-insert-data/_rust_stmt.mdx" +import RustSml from "../../07-develop/03-insert-data/_rust_schemaless.mdx" import RustQuery from "../../07-develop/04-query-data/_rust.mdx" [![Crates.io](https://img.shields.io/crates/v/taos)](https://crates.io/crates/taos) ![Crates.io](https://img.shields.io/crates/d/taos) [![docs.rs](https://img.shields.io/docsrs/taos)](https://docs.rs/taos) @@ -232,6 +233,10 @@ There are two ways to query data: Using built-in types or the [serde](https://se +#### Schemaless Write + + + ### Query data From 4295063bea8e748a6a38816110d7fbe4b59f7b3f Mon Sep 17 00:00:00 2001 From: Adam Ji Date: Mon, 24 Apr 2023 08:54:30 +0800 Subject: [PATCH 11/11] docs: remove db in sml struct --- .../rust/nativeexample/examples/schemaless_insert_json.rs | 7 +++---- .../rust/nativeexample/examples/schemaless_insert_line.rs | 7 +++---- .../nativeexample/examples/schemaless_insert_telnet.rs | 6 ++---- 3 files changed, 8 insertions(+), 12 deletions(-) diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs index 1a0e219462..d5aa45016e 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_json.rs @@ -24,6 +24,9 @@ async fn put_json() -> anyhow::Result<()> { .exec(format!("create database if not exists {db}")) .await?; + // should specify database before insert + client.exec(format!("use {db}")).await?; + // SchemalessProtocol::Json let data = [ r#"[{"metric": "meters.current", "timestamp": 1681345954000, "value": 10.3, "tags": {"location": "California.SanFrancisco", "groupid": 2}}, {"metric": "meters.voltage", "timestamp": 1648432611249, "value": 219, "tags": {"location": "California.LosAngeles", "groupid": 1}}, {"metric": "meters.current", "timestamp": 1648432611250, "value": 12.6, "tags": {"location": "California.SanFrancisco", "groupid": 2}}, {"metric": "meters.voltage", "timestamp": 1648432611250, "value": 221, "tags": {"location": "California.LosAngeles", "groupid": 1}}]"# @@ -33,7 +36,6 @@ async fn put_json() -> anyhow::Result<()> { // demo with all fields let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Json) .precision(SchemalessPrecision::Millisecond) .data(data.clone()) @@ -44,7 +46,6 @@ async fn put_json() -> anyhow::Result<()> { // demo with default precision let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Json) .data(data.clone()) .ttl(1000) @@ -54,7 +55,6 @@ async fn put_json() -> anyhow::Result<()> { // demo with default ttl let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Json) .data(data.clone()) .req_id(302u64) @@ -63,7 +63,6 @@ async fn put_json() -> anyhow::Result<()> { // demo with default req_id let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Json) .data(data.clone()) .build()?; diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs index f4ffc78c54..3cf4d969ce 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_line.rs @@ -25,6 +25,9 @@ async fn put_line() -> anyhow::Result<()> { .exec(format!("create database if not exists {db}")) .await?; + // should specify database before insert + client.exec(format!("use {db}")).await?; + let data = [ "measurement,host=host1 field1=2i,field2=2.0 1577837300000", "measurement,host=host1 field1=2i,field2=2.0 1577837400000", @@ -36,7 +39,6 @@ async fn put_line() -> anyhow::Result<()> { // demo with all fields let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Line) .precision(SchemalessPrecision::Millisecond) .data(data.clone()) @@ -47,7 +49,6 @@ async fn put_line() -> anyhow::Result<()> { // demo with default ttl let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Line) .precision(SchemalessPrecision::Millisecond) .data(data.clone()) @@ -57,7 +58,6 @@ async fn put_line() -> anyhow::Result<()> { // demo with default ttl and req_id let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Line) .precision(SchemalessPrecision::Millisecond) .data(data.clone()) @@ -66,7 +66,6 @@ async fn put_line() -> anyhow::Result<()> { // demo with default precision let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Line) .data(data) .req_id(103u64) diff --git a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs index 944216338e..d2bbc69261 100644 --- a/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs +++ b/docs/examples/rust/nativeexample/examples/schemaless_insert_telnet.rs @@ -24,6 +24,8 @@ async fn put_telnet() -> anyhow::Result<()> { .exec(format!("create database if not exists {db}")) .await?; + // should specify database before insert + client.exec(format!("use {db}")).await?; let data = [ "meters.current 1648432611249 10.3 location=California.SanFrancisco group=2", @@ -40,7 +42,6 @@ async fn put_telnet() -> anyhow::Result<()> { // demo with all fields let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Telnet) .precision(SchemalessPrecision::Millisecond) .data(data.clone()) @@ -51,7 +52,6 @@ async fn put_telnet() -> anyhow::Result<()> { // demo with default precision let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Telnet) .data(data.clone()) .ttl(1000) @@ -61,7 +61,6 @@ async fn put_telnet() -> anyhow::Result<()> { // demo with default ttl let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Telnet) .data(data.clone()) .req_id(202u64) @@ -70,7 +69,6 @@ async fn put_telnet() -> anyhow::Result<()> { // demo with default req_id let sml_data = SmlDataBuilder::default() - .db(db.to_string()) .protocol(SchemalessProtocol::Telnet) .data(data.clone()) .build()?;