使用 Rust 连接器建立连接

创建项目

cargo new --bin cloud-example

增加依赖

在 Cargo.toml 文件中增加下面的依赖：

Cargo.toml
[package]
name = "cloud-example"
version = "0.1.0"
edition = "2021"

[dependencies]
taos = { version = "*", default-features = false, features = ["ws", "ws-rustls"] }
tokio = { version = "1", features = ["full"]}
anyhow = "1.0.0" 

配置

在您的终端里面执行下面的命令设置 TDengine Cloud 的 DSN 为环境变量：

Bash
CMD
Powershell

export TDENGINE_CLOUD_DSN="<DSN>"

set TDENGINE_CLOUD_DSN=<DSN>

$env:TDENGINE_CLOUD_DSN='<DSN>'

IMPORTANT

替换 <DSN> 为您要访问的TDengine Cloud 实例的 DSN 值，格式应该是 wss://<cloud_endpoint>?token=<token>。

获取实例的真实 DSN 的值，请登录TDengine Cloud 后点击左边的”编程“菜单，然后选择”Rust“。

建立连接

复制下面的代码到 main.rs 文件，执行cargo run观察运行结果。

main.rs
use anyhow::Result;
use taos::*;

#[tokio::main]
async fn main() -> Result<()> {
    let dsn = std::env::var("TDENGINE_CLOUD_DSN")?;
    println!("dsn: {}", dsn);
    let taos = TaosBuilder::from_dsn(dsn)?.build().await?;
    let mut res = taos.query("show databases").await?;
    res.rows().try_for_each(|row| async {
        println!("{}", row.into_value_iter().join(","));
        Ok(())
    }).await?;
    Ok(())
}