Query Snowflake
To query Snowflake with Flux:
-
Import the
sql
package. -
Use
sql.from()
and provide the following parameters:- driverName: snowflake
- dataSourceName: See data source name
- query: SQL query to execute
import "sql"
sql.from(
driverName: "snowflake",
dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
query: "SELECT * FROM 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
Snowflake to Flux data type conversion
sql.from()
converts Snowflake data types to Flux data types.
Snowflake data type | Flux data type |
---|---|
FIXED, NUMBER | int or float (depending on decimal size) |
REAL, FLOAT | float |
TIMESTAMP_TZ, TIMESTAMP_LTZ | time |
BOOLEAN | bool |
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
Customers with an annual or support contract can contact InfluxData Support.