snowpipe-streaming-quickstart

Automate Snowpipe Streaming HPA setup with Snowflake provisioning and a Streamlit dashboard.

4|11|Updated Sep 10, 2025
One-click install
npx skills add https://github.com/snowflakedb/snowpipe-streaming-sdk-examples --skill snowpipe-streaming-quickstart
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: snowpipe-streaming-quickstart
Source: https://github.com/snowflakedb/snowpipe-streaming-sdk-examples/tree/main/skills/snowpipe-streaming-quickstart
Command: npx skills add https://github.com/snowflakedb/snowpipe-streaming-sdk-examples --skill snowpipe-streaming-quickstart

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Automates the end-to-end setup and demonstration of Snowpipe Streaming HPA, turning a multi-step process into a reproducible, zero-to-live pipeline that provisions Snowflake objects, creates a demo user, generates RSA keys, and deploys a cloud-based dashboard for real-time monitoring.

Core Features & Use Cases

  • Platform detection & context: detects OS, verifies Python 3.9+, and gathers Snowflake context to tailor the run.
  • RSA key-pair generation: creates a fresh 2048-bit RSA key pair and registers the public key with Snowflake.
  • Snowflake object provisioning: creates database, schema, landing table, demo user and role, and configures access.
  • Local config & venv setup: writes profile.json, streaming_demo.py, and creates an isolated Python virtual environment with necessary dependencies.
  • Real-time dashboard: deploys a Streamlit-based Snowflake dashboard to monitor data in real time.
  • Demo execution & cleanup: streams fake data, summarizes results, and optionally cleans up Snowflake assets.

Quick Start

Run the Snowpipe Streaming Quickstart to automatically provision Snowflake objects, generate keys, configure a local environment, and run a live Streamlit dashboard.

Frequently Asked Questions about snowpipe-streaming-quickstart

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I set up Snowpipe Streaming for real-time data ingestion into Snowflake?

To set up Snowpipe Streaming, you need to provision Snowflake objects, configure RSA key-pair authentication, establish a local Python environment, and execute a streaming script to ingest local data into Snowflake. This quickstart automates that entire end-to-end pipeline.

What is Snowpipe Streaming and how does it differ from standard Snowpipe?

Snowpipe Streaming allows real-time data ingestion directly into Snowflake tables without staging files. This approach uses a streaming client to push data, bypassing cloud storage and enabling immediate data availability for real-time monitoring via a Streamlit dashboard.

Can I monitor real-time Snowflake data ingestion locally without a cloud deployment?

Yes, you can monitor real-time Snowflake data ingestion locally by deploying a Streamlit dashboard. This quickstart provisions a cloud-based Streamlit application that connects directly to your Snowflake environment to visualize streaming data as it arrives.

Does this real-time ingestion quickstart handle Snowflake cleanup after the demo?

Yes, the quickstart includes an optional cleanup step that removes the provisioned Snowflake objects, such as the database, schema, landing table, demo user, and role, ensuring no residual assets remain in your account after the streaming demonstration concludes.

What prerequisites do I need to run a Snowpipe Streaming quickstart demo?

You need Python 3.9 or higher installed locally and an active Snowflake account. The automated quickstart handles the rest, including OS detection, RSA key generation, Snowflake object provisioning, and local virtual environment setup with all necessary dependencies.