2.2 KiB
2.2 KiB
| title | list_title | description | menu | weight | related | list_code_example | |||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Write to Snowflake | Snowflake | Use [`sql.to()`](/flux/v0/stdlib/sql/to/) with the `snowflake` driver to write data to Snowflake. |
|
101 |
|
```js import "sql" data |> sql.to( driverName: "snowflake", dataSourceName: "user:password@account/db/exampleschema?warehouse=wh", table: "example_table", ) ``` |
To write data to Snowflake with Flux:
-
Import the
sqlpackage. -
Pipe-forward data into
sql.to()and provide the following parameters:- driverName: snowflake
- dataSourceName: See data source name
- table: Table to write to
- batchSize: Number of parameters or columns that can be queued within
each call to
Exec(default is10000)
import "sql"
data
|> sql.to(
driverName: "snowflake",
dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
table: "example_table",
)
Snowflake data source name
The snowflake driver uses the following DSN syntaxes (also known as a connection string):
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 to Snowflake data type conversion
sql.to() converts Flux data types to Snowflake data types.
| Flux data type | Snowflake data type |
|---|---|
| float | FLOAT |
| int | NUMBER |
| string | TEXT |
| bool | BOOLEAN |
| time | TIMESTAMP_LTZ |