Snowflake

What you can do

14 actions, each one call from a workflow or a server function. Triggers come from your app: a row changing, a schedule or a webhook.

• Run QueryrunQuery
  Execute a SQL query against your Snowflake database and return the results as rows.
• Create / Refresh Dynamic Tablecreate_dynamic_table
  Create or replace a Snowflake Dynamic Table that automatically refreshes based on a query. Dynamic Tables are a declarative way to define a table whose content is derived from a query, updated on a schedule.
• Delete Rowdelete_row
  Delete one or more rows from a Snowflake table that match a WHERE condition.
• Execute Stored Procedureexecute_stored_procedure
  Call a stored procedure in Snowflake and return its result.
• Get Row by IDget_row_by_id
  Retrieve a single row from a Snowflake table by matching a column value.
• Get Table Schemaget_table_schema
  Retrieve the column definitions (name, data type, nullability, default) for a Snowflake table.
• Insert Multiple Rowsinsert_multiple_rows
  Insert multiple rows into a Snowflake table in a single operation.
• Insert Rowinsert-row
  Insert a row into a table.
• List Tableslist_tables
  List all tables in a Snowflake schema.
• Load Data from Stageload_data_from_stage
  Load data into a Snowflake table from a named internal or external stage using COPY INTO.
• Run Multiple QueriesrunMultipleQueries
  Execute multiple SQL statements in sequence against your Snowflake database. Optionally wrap them in a transaction so all changes are rolled back if any statement fails.
• Search Rowssearch_rows
  Search for rows in a Snowflake table using an optional WHERE condition, ordering, and row limit.

All 14 actions with their inputs

Set it up

About two minutes, once per project or once for the whole workspace.

1. Open Integrations in the builder

   Backend panel, Integrations tab, then Snowflake. To connect it for every project, use Workspace settings, Integrations.

2. Add your credentials

   Fill in the fields the provider needs (listed below). They are stored encrypted in the vault.

   • Account Snowflake account identifier (e.g. xy12345.us-east-1)
   • Username Snowflake login username
   • Password Snowflake login password
   • Database Default database to use
   • Warehouse Compute warehouse to use
3. Call an action

   From a workflow, by integration id and action name. The call answers with success, output and, when it fails, the reason.

   // .workflow.js (native ctx)
   export async function run(ctx) {
     const res = await ctx.integrations.invoke("snowflake", "runQuery", {
       "sqlText": "<sql query>"
     });
     if (!res.success) throw new Error(res.error);
     ctx.log.info("Snowflake answered", { output: res.output });
   }

More in Data and storage

• S3Amazon S3
• Dropbox
• Google Cloud Storage
• MongoDB
• MySQL
• PostgreSQL
• All of Data and storage