build-etl-pipeline

Design idempotent ETL/ELT pipelines with incremental loads and orchestration.

9|3|Updated Jun 13, 2026
One-click install
npx skills add https://github.com/Sir-chawakorn/sanook-cli --skill build-etl-pipeline
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: build-etl-pipeline
Source: https://github.com/Sir-chawakorn/sanook-cli/tree/main/skills/build-etl-pipeline
Command: npx skills add https://github.com/Sir-chawakorn/sanook-cli --skill build-etl-pipeline

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This skill addresses the complexity of building reliable data movement pipelines, preventing common issues like duplicate data, partial loads, and silent failures during ETL/ELT processes.

Core Features & Use Cases

  • Idempotent Design: Ensures that rerunning a pipeline produces the same result without duplicating data or corrupting state.
  • Incremental Processing: Supports watermark-based and CDC patterns to process only new or changed data efficiently.
  • Orchestration Patterns: Provides a framework for building DAGs with proper error handling, dead-letter queues, and validation gates.
  • Use Case: Use this to build a production-grade nightly job that extracts data from a production database, transforms it into a warehouse-ready format, and validates the output for freshness and integrity.

Quick Start

Use the build-etl-pipeline skill to design an incremental load strategy for syncing user activity logs from our production database into the analytics warehouse.

Frequently Asked Questions about build-etl-pipeline

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

FAQPage Schema
How do I build an idempotent ETL pipeline that prevents duplicate data during reruns?

An idempotent ETL pipeline ensures that rerunning the data movement process yields the same result without duplicating records or corrupting state. This approach applies transactional integrity and schema mapping to safely handle partial loads and silent failures.

What is the best way to design incremental loads for syncing a production database to a data warehouse?

The best way to design incremental loads for a data warehouse is using watermark-based patterns or Change Data Capture (CDC). These methods process only new or changed data efficiently, ensuring robust synchronization without reloading entire datasets nightly.

How does dead-letter queue orchestration work in data engineering pipelines?

Dead-letter queue orchestration in data engineering pipelines isolates failed records during extraction or transformation, preventing silent failures. Combined with DAGs and validation gates, it ensures robust error handling and maintains transactional integrity across the pipeline.

Can I use this approach for API ingestion and database synchronization tasks?

Yes, this ETL pipeline design explicitly supports API ingestion and database synchronization tasks. It handles moving data between systems while enforcing transactional integrity, schema mapping, and robust error handling patterns for reliable warehouse population.

Why does my data pipeline produce partial loads and how can I prevent it?

Partial loads in a data pipeline occur when failures interrupt the extraction or transformation process. Preventing them requires an idempotent design with proper error handling, dead-letter queues, and validation gates to ensure complete and reliable data movement.