480+ Blueprints, ready to build.

The first step is always the hardest. Search or browse to kick-start your next flow.

17 Data

AI Business Cloud Core Data Infrastructure

175 Blueprints

Sort by:

Airbyte to dbt to Hightouch Activation with Slack Notification

Airbyte ingests, dbt transforms, Hightouch activates, Slack confirms, the full reverse-ETL chain in one flow.

Clone a Git repository with PySpark code and run a Spark job

Clone a Git repository of PySpark code and run a Spark job with spark-submit, fully orchestrated by Kestra.

Clone a GitHub repository and run a Python ETL script

Clone a GitHub repository and run a version-controlled Python ETL script in an isolated Docker container.

Curate GCS Files into BigQuery with Python

Download a file from Google Cloud Storage, clean it with Python and pandas, and load the curated result into BigQuery on a schedule.

Event Driven Postgres to Databricks Pipeline with Data Quality Checks

React to new Postgres rows, land the data in S3 and Databricks, aggregate it with a Databricks job, and validate the result with a Python data quality check.

Execute a Parameterised SQL Query on Postgres

Run any parameterised SQL query against a Postgres database and store every result row for downstream tasks.

Extract and transform a Parquet file using DuckDB and export it in Excel

Query a remote Parquet file with DuckDB and export the results straight to an Excel spreadsheet.

Extract data from a REST API and send it to a Kafka topic using the Kafka

Fetch data from a REST API and publish it to a Kafka topic with Kestra.

Extract data from an API and load it to Postgres using Python, Git and Docker

Clone Python ETL scripts from Git, extract API data in Docker, and load it into Postgres with Kestra.

Extract data from an API using Python, then load it to Postgres and S3

Extract data from an API with Python, load it into Postgres, and archive a copy to Amazon S3.

Extract data from Apache Pinot into a CSV format and load it into BigQuery

Move Apache Pinot query results into BigQuery as a clean, schema-typed CSV load.

Extract multiple tables from Postgres using SQL queries and process those

Extract multiple Postgres tables in parallel and crunch them into a bestsellers report with Python and Pandas, on a daily schedule.

Extract, Transform, and Store HackerNews Top Stories with AI-Generated Daily Digest

Fetch trending HackerNews stories, store them in PostgreSQL, generate an AI trend digest with OpenAI, and post a daily briefing to Slack.

GPU-accelerated Python script with Modal

Run a GPU-accelerated Python script on Modal's serverless cloud, orchestrated end to end with Kestra.

Load GCS Files into BigQuery on Arrival

Auto-load files into BigQuery the moment they land in a Google Cloud Storage bucket, then archive each object so it never re-triggers.

Process a file from S3 only if it changed since the last execution

Reprocess an S3 file only when it changed, on a schedule, using Python and boto3.

Read a CSV file and load each row into RabbitMQ

Publish each row of a CSV file as a message to a RabbitMQ exchange with Kestra.

Read a Google Spreadsheet & Load it to BigQuery

Read a Google Spreadsheet and load its rows straight into a BigQuery table with automatic schema detection.

Run a Papermill notebook

Parameterize and run a Jupyter notebook end to end with Papermill inside a Kestra Python task.

Run a Shell script as a subprocess on the Kestra host

Run a Shell script directly on the Kestra host as a child process using the lightweight Process task runner.

Run a ZenML flow from Kestra until its completion and stream logs in real-time

Run a ZenML machine learning pipeline from Kestra on a schedule, with logs streamed in real time.

Sync Google Sheets Leads to a Mailchimp Subscriber List

Poll a Google Sheet every 2 minutes and subscribe each lead's email to a Mailchimp audience automatically.

Triage Stale GitLab Issues and Create a Weekly Report

Automatically find stale GitLab issues every week and open a triage tracking issue for your team.

Trigger multiple Fivetran syncs in parallel, then run a dbt job

Run four Fivetran connector syncs in parallel, then build your dbt Core models on the freshly loaded data.