写入 Snowflake
使用 Flux 将数据写入 Snowflake
导入
sql
包。将数据管道转发到
sql.to()
并提供以下参数- driverName: snowflake
- dataSourceName: 请参阅 数据源名称
- table: 要写入的表
- batchSize: 每次调用
Exec
时可以排队的参数或列的数量(默认为10000
)
import "sql"
data
|> sql.to(
driverName: "snowflake",
dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
table: "example_table",
)
Snowflake 数据源名称
snowflake
驱动程序使用以下 DSN 语法(也称为连接字符串)
username[:password]@accountname/dbname/schemaname?param1=value1¶mN=valueN
username[:password]@accountname/dbname?param1=value1¶mN=valueN
username[:password]@hostname:port/dbname/schemaname?account=<your_account>¶m1=value1¶mN=valueN
Flux 到 Snowflake 数据类型转换
sql.to()
将 Flux 数据类型转换为 Snowflake 数据类型。
Flux 数据类型 | Snowflake 数据类型 |
---|---|
float | FLOAT |
int | NUMBER |
string | TEXT |
bool | BOOLEAN |
time | TIMESTAMP_LTZ |
此页内容对您有帮助吗?
感谢您的反馈!