This repository contains examples demonstrating how to use the Snowpipe Streaming SDK to ingest data into Snowflake in real-time.
The Snowpipe Streaming SDK enables applications to stream data directly into Snowflake tables with low latency and high throughput. This repository provides practical examples to help you get started with the SDK quickly.
This repository contains complete, runnable examples in multiple languages:
A complete Maven project demonstrating the Snowpipe Streaming SDK in Java. Includes:
- Maven build configuration with all required dependencies
- Full example code with proper error handling
- Comprehensive setup instructions
- Sample configuration files
A complete Python project demonstrating the Snowpipe Streaming SDK in Python. Includes:
- Requirements file with all necessary packages
- Clean, well-documented example code
- Setup instructions with virtual environment
- Sample configuration files
- Choose your preferred language (Java or Python)
- Navigate to the respective example directory
- Follow the README instructions in that directory to:
- Set up your Snowflake table and pipe
- Configure authentication
- Install dependencies
- Run the example
Dependencies: The dependency versions used in the examples are for demonstration purposes only. These should be updated appropriately based on the SDK version you are using.
This project is licensed under the CC BY 4.0 license.