This project demonstrates a data pipeline using Snowflake, Google Cloud Storage (GCS), and Pub/Sub for loading data incrementally into Snowflake tables. The pipeline is triggered by new files arriving in a specified GCS bucket, notifying Snowflake through Pub/Sub, and subsequently updating tables in Snowflake.

Production-style SCD Type 1 data pipeline built with Snowflake and AWS S3, featuring automated ingestion via Snowpipe, change detection with Streams, and conditional orchestration using Tasks and stored procedures. Demonstrates warehouse-native ELT and dimensional modeling best practices.