data-engineer

Automate batch and real-time ETL pipelines with schema validation and monitoring.

34|7|Updated Oct 22, 2025
One-click install
npx skills add https://github.com/daffy0208/ai-dev-standards --skill data-engineer-daffy0208
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: data-engineer
Source: https://github.com/daffy0208/ai-dev-standards/tree/main/SKILLS/data-engineer
Command: npx skills add https://github.com/daffy0208/ai-dev-standards --skill data-engineer-daffy0208

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill solves the challenge of building scalable, reliable data infrastructure by automating ETL processes, ensuring data quality, and designing efficient data warehouses.

Core Features & Use Cases

  • ETL Pipeline Development: Create automated data pipelines for batch and real-time processing.
  • Data Transformation & Validation: Clean, enrich, and validate data using schema validation and quality checks.
  • Use Case: Imagine you need to sync customer data from Stripe to your database daily. Use this Skill to build a complete ETL pipeline with validation, monitoring, and error handling.

Quick Start

Use the data-engineer skill to design a star schema for sales analytics with date, customer, product, and location dimensions.

Frequently Asked Questions about data-engineer

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

FAQPage Schema
How do I build an ETL pipeline for batch and real-time data processing?

ETL pipelines automate extraction, transformation, and loading of data from multiple sources into a centralized warehouse. Use schema validation with Prisma and Zod, implement data quality checks, and orchestrate jobs with Kafka for streaming or scheduled batch runs to ensure reliable data delivery across databases and warehouses.

What's the best way to ensure data quality in automated pipelines?

Data quality is enforced through type-safe validation, schema enforcement, and automated quality checks within the transformation layer. This catches errors before data reaches your warehouse, preventing downstream analytics issues and maintaining data integrity across batch and real-time processes.

Can I use Kafka and PostgreSQL together for streaming and batch ETL?

Yes. Kafka handles real-time data streams while PostgreSQL stores transformed data; both integrate within a unified ETL architecture. This dual-platform approach lets you process continuous streams and scheduled batches, with Redis caching and monitoring to optimize performance and reliability.

How do I design a data warehouse schema for analytics?

Star schema design organizes data into fact tables (central events) and dimension tables (customers, products, dates, locations). This structure optimizes query performance for analytics and reporting while maintaining data normalization and clean separation of concerns for scalable, efficient warehouses.

What monitoring and orchestration tools work with data pipelines?

Kafka manages event streaming, Redis provides caching, scheduled jobs orchestrate batch runs, and PostgreSQL persists transformed data. Together they provide end-to-end monitoring, error handling, and reliability for production ETL infrastructure serving analytics requirements.

Do I need schema validation for data transformation and loading?

Schema validation is essential for type safety and data integrity. Using Prisma and Zod enforces strict validation during transformation, catching misaligned or invalid data before loading into your warehouse and preventing corruption or analytics failures downstream.