写入Snowflake

使用Flux将数据写入Snowflake：

1. 导入 sql 包。

2. 将数据通过管道传递到 sql.to() 并提供以下参数：

   • driverName: 雪花
   • dataSourceName: 查看数据源名称
   • table: 要写入的表
   • batchSize: 每次调用Exec时可以排队的参数或列的数量（默认为10000）

import "sql"
  
data
    |> sql.to(
        driverName: "snowflake",
        dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
        table: "example_table",
    )

雪花数据源名称

雪花驱动程序使用以下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

Flux 到 Snowflake 数据类型转换

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