Connectors

Databases & Data Warehouses

Snowflake

Cloud data warehouse: run SQL queries, load data, and manage warehouses
Signs in with
Connection details
Runs on
Cloud or On-Prem Worker
Operations
7
Ready-made triggers
0

Connect Snowflake

  1. In Neblex open Connect › Connections and click New Connection.
  2. Search for Snowflake and give the connection a clear name.
  3. Fill in the fields. Secret values are encrypted and never shown again.
  4. Click Test, then Create Connection.
If the system is only reachable inside your network, choose an On-Prem Worker under Test from and run the flow on that Worker. See On-Prem Workers.
FieldWhat to enter
Account identifierRequirede.g. xy12345.eu-central-1 (the part before .snowflakecomputing.com).
UserRequired
Private key (PKCS#8 PEM)RequiredSecretThe RSA private key registered on the user (ALTER USER ... SET RSA_PUBLIC_KEY). Unencrypted PKCS#8 PEM.
WarehouseOptional
DatabaseOptional
SchemaOptional
RoleOptional

Use it in a flow

  1. Open a flow, open the node library and search for Snowflake.
  2. Drag it onto the canvas and choose an Operation and your connection.
  3. Map the operation's fields from earlier steps, or click Map with Matt.
  4. Use Test this step to see what it returns, then save.

To start a flow from Snowflake without a ready-made trigger: a Poll for changes trigger on Snowflake with your own query passes on new or changed records.

Operations

7 operations in 3 groups. Each one is a step you can add to a flow.

Connection1
Test SnowflakepingRun a minimal statement through the Snowflake SQL API.
Metadata5
Get server timeserverTimeReturn Snowflake's current timestamp.
Get server versionserverVersionReturn the current Snowflake server version.
Get table row counttableRowCountReturn Snowflake catalog row-count metadata for every matching table.
List table columnslistColumnsList columns for every visible table matching the supplied name.
List tableslistTablesList visible tables and views with their catalog, schema, and type.
SQL1
Execute Snowflake SQLqueryExecute arbitrary Snowflake SQL with server-side bound parameters.