Use-cases
Users
Industries
Hi! I'm your Kestra AI assistant.Ask me anything about workflows.
EXAMPLE QUESTIONS
The first step is always the hardest. Search or browse to kick-start your next flow.
175 Blueprints
Export a Slack channel's history to internal storage and load it into BigQuery on a schedule.
Extract sales data to S3, aggregate it with DuckDB, and email a CSV report on the first of every month.
Run a chain of SurrealDB CRUD queries with Kestra and post the final result to Slack.
Query Snowflake every morning, format the metrics as Markdown, and publish them as an editable Slack Canvas.
Poll a SQL Server queue-style table for pending rows, flip them to processed in the same transaction, and fan out to a per-row task the moment work appears.
Run a Kestra workflow automatically whenever a Snowflake query returns matching rows.
Download a CSV over HTTP, truncate-and-reload an Oracle staging table with named-column JDBC batches, then assert the row count landed.
Extract CSV data, mask PII columns with DuckDB SQL, then load the anonymized result into BigQuery.
Refresh a daily sales aggregate in Postgres, then publish three differently-shaped completion events to independent NATS subjects for fulfillment, analytics, and audit teams.
Poll Oracle for new orders, enrich them with customer data, claim the exact batch, and MERGE it into a mart table so replays never duplicate.
Clone a SQLMesh project from Git, run `sqlmesh plan --auto-apply`, and query the resulting DuckDB database with Kestra.
Run a SQL query against your Snowflake data warehouse and capture the results in Kestra.
Insert records into SurrealDB and store query results as downloadable artifacts in Kestra internal storage.
Call a REST API on a daily schedule, reshape the JSON with jq, bulk load it into Postgres with COPY, and notify Slack on success or failure.
Nightly job that lists a self-hosted MinIO bucket, filters objects older than a retention window in Python, and deletes only the expired ones.
Run a UTC-anchored, backfillable Oracle SQL report on a daily schedule, convert it to CSV, and email it, skipping the send when there is no data and alerting Slack on failure.
Run a daily SQL Server aggregate query, convert it to CSV, and email it as an attachment, skipping empty days and alerting Slack on failure.
End-to-end Snowflake ETL with Kestra: create a database and table, stage a CSV, COPY INTO Snowflake, and run analytical SQL.
Stage a delta file, COPY into a staging table, and MERGE into the Snowflake target as one atomic transaction for an idempotent upsert.
Poll a Snowflake stream for new rows, load each batch into Postgres in parallel, run dbt transformations, and alert Slack on failure.
Stream SQL Server row-level changes in real time with the Debezium SQL Server connector and alert Microsoft Teams on high-value changes, no Kafka Connect required.
Extract changed rows from a source SQL Server table since the last KV-tracked watermark and bulk-insert them into a destination instance with chunked JDBC batches.
Stage changed rows since a KV-tracked watermark, MERGE them into a target table with dedup, and advance the watermark, all inside one SQL Server transaction.
Fetch Stripe charges and customers, enrich them in Python, and upsert into a PostgreSQL CRM table on a daily schedule with idempotent deduplication.
