databricks-pipelines

Develop batch and streaming data pipelines on Databricks with Lakeflow Spark Declarative Pipelines.

251|71|Updated Jan 14, 2026
One-click install
npx skills add https://github.com/databricks/databricks-agent-skills --skill databricks-pipelines
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-pipelines
Source: https://github.com/databricks/databricks-agent-skills/tree/main/skills/databricks-pipelines
Command: npx skills add https://github.com/databricks/databricks-agent-skills --skill databricks-pipelines

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

This Skill simplifies the development of complex batch and streaming data pipelines on Databricks using Lakeflow Spark Declarative Pipelines (formerly Delta Live Tables), enabling efficient and reliable data processing.

Core Features & Use Cases

  • Declarative Pipeline Development: Define data pipelines using Python or SQL with a focus on desired outcomes rather than imperative steps.
  • Streaming and Batch Processing: Supports both continuous data streams and batch data processing with features like Auto Loader, Auto CDC, and Materialized Views.
  • Data Quality Enforcement: Integrate data quality checks using Expectations to ensure data integrity throughout the pipeline.
  • Use Case: Develop a robust ETL pipeline that ingests streaming data from cloud storage, cleanses and transforms it into a silver layer, and then aggregates it into a gold layer for business intelligence, all while enforcing data quality rules.

Quick Start

Use the databricks-pipelines skill to create a new Databricks Asset Bundle project for a Lakeflow pipeline.

Frequently Asked Questions about databricks-pipelines

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I build a streaming ETL pipeline on Databricks from bronze to gold layers?

You can build streaming ETL pipelines on Databricks using Lakeflow Spark Declarative Pipelines to ingest, cleanse, and aggregate data from bronze to gold layers. The Skill supports declarative development in Python or SQL to define the entire workflow.

What is the best way to enforce data quality expectations in a Databricks data pipeline?

Enforcing data quality in a Databricks data pipeline is done by integrating data quality expectations directly within Lakeflow Spark Declarative Pipelines. This ensures data integrity is validated continuously throughout the ETL processing stages.

Can I use Auto Loader and incremental refresh for batch processing in Databricks Lakeflow pipelines?

Yes, Databricks Lakeflow pipelines support both batch processing and streaming using Auto Loader and incremental refresh. This allows you to process continuous data streams and batch data efficiently within the same declarative framework.

Do I need to use SQL or Python to develop declarative data pipelines with Delta Live Tables?

You can develop declarative data pipelines using either Python or SQL. Lakeflow Spark Declarative Pipelines, formerly Delta Live Tables, allows you to define desired outcomes in both languages without relying on imperative processing steps.

Does this approach support Auto CDC and Materialized Views for ELT workflows?

Yes, building ELT workflows with Lakeflow Spark Declarative Pipelines supports Auto CDC and Materialized Views. These features facilitate capturing change data and maintaining aggregated states for downstream business intelligence.

When should I use Databricks Asset Bundles for a Lakeflow pipeline project?

Use Databricks Asset Bundles when you need to create a new project structure for a Lakeflow pipeline. It provides the foundational setup to begin developing declarative ETL workflows that process streaming and batch data.