data-pipeline-engineer

Design ETL/ELT pipelines with Spark, Kafka, Airflow, and dbt.

181|30|Updated Nov 16, 2025
One-click install
npx skills add https://github.com/curiositech/some_claude_skills --skill data-pipeline-engineer-curiositech
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: data-pipeline-engineer
Source: https://github.com/curiositech/some_claude_skills/tree/main/.claude/skills/data-pipeline-engineer
Command: npx skills add https://github.com/curiositech/some_claude_skills --skill data-pipeline-engineer-curiositech

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill helps you design, build, and maintain reliable data pipelines for ETL/ELT processes, streaming data, and data warehousing, preventing common pitfalls and ensuring data quality.

Core Features & Use Cases

  • Architecture Design: Guides you through choosing between Medallion, Lambda, or Kappa architectures.
  • Technology Integration: Provides patterns for Spark, Kafka, Airflow, and dbt.
  • Data Quality: Integrates Great Expectations and dbt tests for validation.
  • Use Case: You need to build a daily batch pipeline to ingest sales data from a transactional database, transform it into a star schema for reporting, and ensure data accuracy at each stage.

Quick Start

Use the data-pipeline-engineer skill to create an Airflow DAG for a batch ETL process.

Frequently Asked Questions about data-pipeline-engineer

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

FAQPage Schema
How do I build a batch ETL pipeline to ingest data and transform it into a star schema?

To build a batch ETL pipeline for a star schema, you can use this Skill to design an Airflow DAG that orchestrates data ingestion from a transactional database, applies transformations, and ensures data accuracy at each stage.

What's the best way to orchestrate data pipelines using Airflow and dbt?

The best way to orchestrate data pipelines with Airflow and dbt is to use this Skill to generate integration patterns that schedule workflows, execute transformations, and run dbt tests for data validation.

How do I choose between Medallion, Lambda, and Kappa architectures for data warehousing?

To choose between Medallion, Lambda, and Kappa architectures for data warehousing, this Skill guides you through selecting the right streaming and batch processing architecture based on your specific production requirements.

Can I use Spark and Kafka together for stream processing and batch processing?

Yes, you can use Spark and Kafka together for stream processing and batch processing, as this Skill provides technology integration patterns for building robust streaming architectures and handling both processing methods.

How do I integrate Great Expectations for data quality checks in an ELT pipeline?

To integrate Great Expectations for data quality checks in an ELT pipeline, this Skill helps you incorporate validation frameworks alongside dbt tests to prevent common anti-patterns and ensure data accuracy.

What are common data pipeline anti-patterns I should avoid in production?

Common data pipeline anti-patterns to avoid in production include inadequate data quality checks and poor orchestration, which this Skill addresses by providing patterns for Great Expectations, dbt tests, and robust architecture design.