Learn how to auto-ingest streaming data into Snowflake using Snowpipe.

SQL Scripts related to my learning on the Snowflake data cloud provider

Generating Streaming Data for Snowpipe Streaming

SQL, Databases, warehouses, Data lake, cloud storage, MYSQL, Data Pipeline

CLI script for interacting with Snowpipe REST APIs

SQL, Databases, warehouses, Data lake, cloud storage, MYSQL, Data Pipeline

Realtime data pipeline using Kafka + Spark + AWS S3 (Terraform) + Snowflake

The goal is to build an example of a simple data collection pipeline which collects data from multiple customers and uploads the data to Snowflake could look like. The OpenMeteo Api acts as the "customer system" in this case.

Snowflake DataScience Realtime HandsOn Projects

Advanced Healthcare Claims Pipeline using Snowflake, Snowpipe, Streams, Tasks, SCD Type 2, and AWS S3. Automates ingestion, CDC, dimensional modeling, and data quality checks for healthcare patient and claims data.

Automated Snowflake pipeline using Snowpipe, Streams, Tasks, MERGE logic, and AWS S3.

Real-time ETL (Extract, Transform, Load) data pipeline to process insurance claims data with Snowflake, Apache Airflow, AWS S3, EC2, python pandas and creating a real time data visualization dashboard using Tableau.

❄️ Stream real-time data into Snowflake with Amazon Kinesis Firehose

Automatically move data from AWS S3 to Snowflake datawarehouse continuously with snowpipe

This project showcases a scalable ETL pipeline that automates the extraction, transformation, and storage of Redfin housing market data using AWS, Apache Airflow, and Snowflake, with Power BI for data visualization. The pipeline is configured to run monthly, ensuring your data remains up-to-date.

End-to-End ETL Pipeline for Live Cricket Streaming Data Using AWS (Lambda, Glue, Step Functions, S3), Snowflake, and Power BI for Visualization