查询 Snowflake

要使用 Flux 查询 Snowflake

1. 导入 sql 包。

2. 使用 sql.from() 并提供以下参数

   • driverName: snowflake
   • dataSourceName: 请参阅数据源名称
   • query: 要执行的 SQL 查询

import "sql"

sql.from(
    driverName: "snowflake",
    dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
    query: "SELECT * FROM example_table",
)

Snowflake 数据源名称

snowflake 驱动程序使用以下 DSN 语法（也称为连接字符串）

username[:password]@accountname/dbname/schemaname?param1=value1&paramN=valueN
username[:password]@accountname/dbname?param1=value1&paramN=valueN
username[:password]@hostname:port/dbname/schemaname?account=<your_account>&param1=value1&paramN=valueN

Snowflake 到 Flux 数据类型转换

sql.from() 将 Snowflake 数据类型转换为 Flux 数据类型。