Snowflake Snap Pack examples

Example Snaps used

Load binary data

This example pipeline demonstrates how to convert staged data into binary data using the binary file format before loading it into the Snowflake database.

Provide metadata in the table

This example pipeline demonstrates how to convert staged data into binary data using the binary file format before loading it into the Snowflake database.

Transform data using a select query

This example pipeline demonstrates how to reorder columns using the SELECT statement transform option before loading data into the Snowflake database using the Snowflake - Bulk Load Snap.

Bulk load records

This example pipeline demonstrates how to update a record using the Snowflake Bulk Upsert Snap, routing invalid records that cannot be inserted to an error view.

Upsert records

This example pipeline demonstrates how to update a record using the Snowflake Bulk Upsert Snap, routing invalid records that cannot be inserted to an error view.

Delete record

This example pipeline demonstrates how the Snowflake Delete Snap deletes a record from the ADOBEDATA123 Snowflake database table.

Execute SQL query

This example pipeline demonstrates how to execute a Snowflake SQL query using the Snowflake Execute Snap.

Use result query

This example pipeline demonstrates how to insert data into a table using the Snowflake Execute Snap.

Support UDFs

This example pipeline demonstrates how to execute user-defined functions (UDFs) created in the Snowflake console using the Snowflake - Execute Snap by defining the SQL statement and running the Snap with the specified conditions.

Insert data into table

This example pipeline demonstrates how to read data from a table in Oracle and insert it into a Snowflake table using the Snowflake - Insert Snap.

Look up object record

This example pipeline demonstrates how to look up a Snowflake object record using the Snowflake Lookup Snap and record the data using the Snowflake Execute Snap.

Process multiple queries

This example pipeline demonstrates how to process multiple Snowflake queries in a single transaction.

Historize incoming records

This example pipeline demonstrates how to auto-historize incoming records using the Snowflake SCD2 Snap. The pipeline reads, parses, maps, historizes, and then upserts data into the Snowflake target table.

Read a table from Snowflake

This example pipeline demonstrates how to use the Snowflake - Select Snap to read data from a Snowflake table. The Snap queries the test@test table, orders the results by the C1 column, and limits the output to 10 rows.

Ingest Data from a Source into Snowflake

This example pipeline demonstrates how to use the Snowflake - Snowpipe Streaming Snap to ingest data into the Snowflake database from a source as and when it is available.

Ingest Data from One Table to Another in Snowflake

This example pipeline demonstrates how to read data from one Snowflake table and stream it into another table. The Snowflake Select Snap reads the source table, and the Snowpipe Streaming Snap writes the selected records to the target table.

Retrieve table

This example pipeline demonstrates how the Snowflake Table List Snap retrieves all the tables under the PUBLIC schema and writes them to the output view.

Unload binary data to S3

This example pipeline demonstrates how to unload binary data from a Snowflake table and write it to an Amazon S3 bucket using the Snowflake - Unload Snap along with a JSON Formatter Snap and File Writer Snap.

Update binary records

This example pipeline demonstrates how to encode binary data (such as employee biodata) and update the corresponding employee records in the Snowflake database using the Snowflake - Update Snap.