Snowflake Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Send data to a Snowflake Database. This Kamelet expects a JSON-formatted body. Use key:value pairs to map the JSON fields and parameters.
Configuration Options
The following table summarizes the configuration options available for the snowflake-sink
Kamelet:
Property | Name | Description | Type | Default | Example |
---|---|---|---|---|---|
Instance URL | Required The Instance url. | string | instance.snowflakecomputing.com | ||
Password | Required The password to access a secured Snowflake Database. | string | |||
Query | Required The query to execute against the Snowflake Database. | string | INSERT INTO accounts (username,city) VALUES (:#username,:#city) | ||
Username | Required The username to access a secured Snowflake Database. | string | |||
Database Name | The name of the Snowflake Database. | string |
Dependencies
At runtime, the snowflake-sink
Kamelet relies upon the presence of the following dependencies:
-
camel:jackson
-
camel:kamelet
-
camel:sql
-
mvn:net.snowflake:snowflake-jdbc:3.24.2
-
mvn:org.apache.commons:commons-dbcp2:2.13.0
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel
Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:timer-source"
parameters:
period: 10000
message: 'test'
steps:
- to:
uri: "kamelet:snowflake-sink"
You can now run it directly through the following command
camel run route.yaml
Snowflake Sink Kamelet Description
Cloud Data Warehouse
This Kamelet integrates with Snowflake, a cloud-based data warehouse platform that provides scalable data storage and analytics capabilities. Snowflake is designed for modern data architecture and cloud-native applications.
JDBC Connectivity
Uses the Snowflake JDBC driver for native connectivity to Snowflake instances. The driver provides optimized performance and supports Snowflake-specific features and data types.
Instance Configuration
Requires configuration of the Snowflake instance URL (e.g., instance.snowflakecomputing.com
) which uniquely identifies your Snowflake account and region.
Data Processing
Processes JSON input data through unmarshalling before executing SQL queries. This enables seamless integration with JSON-based data pipelines and streaming applications.