Exploring the concept of streams to capture table-level changes

In this recipe, we will explore the concept of streams, configure a stream on a table, and capture the changes that occur at the table level. Streams are Snowflake's way of performing change data capture on Snowflake tables and can be useful in data pipeline implementation.

Getting ready

The steps for this recipe can be run either in the Snowflake web UI or the SnowSQL command-line client.

How to do it…

The steps for this recipe are as follows:

1. Let's start by creating a database and a staging table on which we will create our stream object. We create a staging table to simulate data arriving from outside Snowflake and being processed further through a stream object:

   CREATE DATABASE stream_demo;
   USE DATABASE stream_demo;
   CREATE TABLE customer_staging
   (
     ID INTEGER,
     Name STRING,
     State STRING,
     Country STRING
   );

2. The process of creating...