---
name: Engineering Data Pipelines
slug: engineering-data-pipelines
category: Data
description: Engineering Data Pipelines covers Airflow, Dagster, Kafka Streams, Flink, dbt, and data quality checks for building ETL workflows and stream processing systems. Use it when designing orchestration, incremental loads, or validation checks.
github: "https://github.com/telagod/code-abyss/tree/main/skills/engineering-data-pipelines"
language: JavaScript
stars: 239
forks: 32
install: "npx degit https://github.com/telagod/code-abyss/tree/main/skills/engineering-data-pipelines ~/.claude/skills/engineering-data-pipelines"
installs_to: ~/.claude/skills/engineering-data-pipelines
source_path: skills/engineering-data-pipelines/SKILL.md
collection_size: 25
category_size: 710
collection_url: "https://dirskills.com/collections/telagod/code-abyss"
added: 2026-09-03T06:03:49.112Z
last_synced: 2026-09-03T06:03:49.112Z
canonical_url: "https://dirskills.com/skills/engineering-data-pipelines"
---

# Engineering Data Pipelines

Engineering Data Pipelines covers Airflow, Dagster, Kafka Streams, Flink, dbt, and data quality checks for building ETL workflows and stream processing systems. Use it when designing orchestration, incremental loads, or validation checks.

**Install:**

```bash
npx degit https://github.com/telagod/code-abyss/tree/main/skills/engineering-data-pipelines ~/.claude/skills/engineering-data-pipelines
```

## README

# 数据工程域 · Data Engineering

> **判断先于执行**：决定「是否做 / 选什么 / 如何取舍」（栈、方案、架构、权衡）前，先读领域判断内核 `skills/_kernel/backend/SKILL.md`——它管 judgment，本秘典管 execution；冲突时以内核判断为准。

```
编排：Airflow(调度) | Dagster(资产) | Prefect(现代流)
流处理：Kafka Streams(嵌入式) | Flink(集群) | Spark Streaming
质量：Great Expectations | dbt tests | Soda Core
```

## 编排检查项

幂等(UPSERT/分区覆盖) | 增量(`WHERE updated_at > last_run`) | 事件驱动触发 | 跨 DAG 依赖 | 数据血缘(`ref()`/Asset deps)

## 流处理检查项

时间语义选择 | Watermark 乱序容忍 | 状态 TTL 防膨胀 | Checkpoint 间隔 | 端到端 Exactly-Once | 背压监控

## 质量检查项

分层验证(源→转换→目标) | 完整性+准确性+一致性 | 及时性阈值 | 加权评分 | 告警(Slack/PagerDuty)

工具对比、API 用法、质量维度详见 [references/details.md](references/details.md)