Snowflake

Snowflake runs the SQL, the warehouse and the stage. Kestra decides when it runs, what feeds it and what runs next, from file arrival to dbt transforms.

  • Technology partner
  • United States
  • North America
Book a DemoWebsite

About

The io.kestra.plugin.jdbc.snowflake plugin turns stage uploads, COPY INTO, multi-statement transactions and polling triggers into declarative tasks that chain with Airbyte ingestion and dbt in one flow.

Snowflake + Kestra: everything around the warehouse, orchestrated

  • Stage loading end to end

    Upload pushes a file to a Snowflake stage, then Query runs the COPY INTO. A failed COPY retries without uploading the file again.

  • Transactional incremental loads

    Queries runs the staging COPY, the MERGE and the watermark update as one transaction, so a failure rolls back and no partial batch lands.

  • Flows that start on data

    The Snowflake Trigger polls the warehouse and starts a flow when a query returns rows, then marks them processed with afterSQL.

  • Warehouse cost control

    Resume a warehouse, run the workload and suspend it in the same flow. Query tags tie credit usage back to the execution that issued each statement.

Snowflake Blueprints

Query data in Snowflake

Run a SQL query against your Snowflake data warehouse and capture the results in Kestra.

Query icon
Data
Snowflake Warehouse Credit Usage and FinOps Cost Guard

Audit Snowflake warehouse credit consumption hourly, detect budget overruns, file GitHub FinOps issues, and alert Slack.

Schedule icon
Query icon
Return icon
If icon
Create icon
SlackIncomingWebhook icon
+1
CloudData
Daily Snowflake Digest as a Slack Canvas

Query Snowflake every morning, format the metrics as Markdown, and publish them as an editable Slack Canvas.

Schedule icon
Query icon
Script icon
Docker icon
Create icon
BusinessData

Other partners

See all partners
DigitalOcean
DigitalOcean

DigitalOcean is the developer cloud, offering droplets, managed databases, and Kubernetes. With Kestra's dedicated plugin, teams orchestrate the whole account with event-driven flows.

TechnologyCloud & Kubernetes

United States North America

HashiCorp
HashiCorp

Manage Kestra with the official Terraform provider, run Terraform plan and apply as governed steps in a flow, and read secrets from HashiCorp Vault.

TechnologyInfrastructure & DevOps

United States North America

Databricks
Databricks

Databricks provides a unified analytics platform for data engineering, data science, and machine learning.

TechnologyDataAI & ML

United States North America