<< All versions

Skill v1.0.0

currentLLM-judged scan90/100
irahardianto/agy-perf-optimization-demo/data-engineering
──Details
PublishedOctober 21, 2026 at 07:42 AM
Content Hashsha256:d884bd1ef02d3656...
Git SHA0a8268560841
──Files
Files (1 file, 2.7 KB)
SKILL.md2.7 KBactive
SKILL.md · 82 lines · 2.7 KB

version: "1.0.0" name: data-engineering description: >- Data pipeline architecture, ETL/ELT patterns, data quality, batch vs stream processing, orchestration, and data governance principles.


Data Engineering Principles

Guidelines for building reliable, scalable data pipelines and platforms.

When to Invoke

  • Designing data pipelines (ETL/ELT)
  • Evaluating batch vs stream processing
  • Data quality and governance requirements
  • Data warehouse/lake architecture decisions

Pipeline Architecture

Design Principles

  1. Idempotent pipelines — re-running produces same result. Use upserts, not inserts.
  2. Schema evolution — handle new fields without breaking consumers.
  3. Exactly-once processing — deduplication at ingestion, idempotency keys.
  4. Incremental processing — process only new/changed data, not full reloads.

Patterns

PatternWhen to Use
Batch ETLScheduled, high volume, latency-tolerant
StreamingReal-time, event-driven, low latency
LambdaBoth batch and stream (complexity trade-off)
KappaStream-only, reprocessing via replay
MedallionBronze (raw) → Silver (cleaned) → Gold (curated)

Data Quality

Checks (Non-Negotiable)

  • Completeness — no unexpected nulls in required fields
  • Uniqueness — no duplicate records on primary keys
  • Referential integrity — foreign keys resolve
  • Freshness — data arrives within SLA window
  • Volume — row counts within expected range (±threshold)

Framework

Source → Validate (schema, nulls, types) → Transform → Validate (business rules) → Load → Verify (counts, checksums)

Orchestration

ToolStrength
Apache AirflowMost mature, Python-native, DAG-based
DagsterType-safe, asset-oriented, modern
PrefectPythonic, flow-based, cloud-native

Best Practices

  • DAGs should be idempotent and retriable
  • Separate orchestration from computation
  • Use backfill capabilities for historical reprocessing
  • Alert on SLA breaches, not just failures

Data Modeling

ModelWhen
Star schemaAnalytics, BI dashboards, simple queries
Data VaultEnterprise, auditability, multiple sources
DimensionalAggregated reporting, OLAP

Governance

  • Data lineage tracked (source → transformation → destination)
  • Access controls per dataset/table
  • PII identified and masked/encrypted
  • Retention policies documented and automated

Related

  • Database Design Principles @.agents/rules/database-design-principles.md
  • SQL Idioms @.agents/skills/sql-idioms/SKILL.md
  • Logging Implementation @.agents/skills/logging-implementation/SKILL.md
All versions