# ETL Pipeline

Скилл для проектирования и автоматизации ETL-пайплайнов: извлечение из баз и API, трансформации, загрузка в хранилища. Пригодится, когда нужно собрать регулярный поток данных.

- скилл · `type=skill` · Claude Code, Codex, Cursor, GitHub Copilot, Gemini CLI, OpenCode · 4800 установок · ★ 540
- Автор: Claude Office Skills
- Лицензия: MIT · policy=mirror · начало файла — в конце страницы
- Исходник: https://github.com/claude-office-skills/skills/tree/HEAD/etl-pipeline/SKILL.md
- Обновлён: 2026-01-31
- HTML: https://affpapa.org/nevibecode/skills/etl-pipeline

## Что делает

Скилл описывает полный цикл пайплайна: извлечение из Postgres, MySQL, MongoDB, REST API и файлов CSV/JSON, слой трансформаций и загрузку в BigQuery, Snowflake, Redshift или data lake. Внутри — готовые схемы конфигураций на YAML, примеры трансформаций на Python и SQL, правила агрегации и join-операций.

Оркестрация задаётся через DAG: расписание, зависимости между задачами, шаги extract, transform, load и уведомление в Slack. Для сбоев есть блок error_handling с повторами, экспоненциальной задержкой и dead letter queue в S3. Отдельный раздел — проверки качества данных: not_null, диапазоны значений и прочие правила с уровнями серьёзности.

Работа с источниками идёт через MCP-сервер `data-mcp` с инструментами `postgres_query`, `mysql_query`, `mongodb_aggregate`, `bigquery_load` и `snowflake_api`. Без этого сервера скилл не сможет обращаться к базам напрямую — это повод проверить свою конфигурацию MCP до запуска. Схемы в примерах используют плейсхолдеры вроде `${execution_date}` и `${start_date}`, их нужно подставить под свои таблицы.

## Установка

### Claude Code (родная платформа)

1. **Через Skills CLI (Vercel)**
```bash
npx skills add claude-office-skills/skills --skill etl-pipeline -a claude-code
```

2. **Вручную: положить файлы**
- Файл: `~/.claude/skills/etl-pipeline/SKILL.md` — Папка скилла целиком; для одного проекта — .claude/skills/etl-pipeline/

### Codex

1. **Через Skills CLI (Vercel)**
```bash
npx skills add claude-office-skills/skills --skill etl-pipeline -a codex
```

2. **Вручную: положить файлы**
- Файл: `.agents/skills/etl-pipeline/SKILL.md` — Для всех проектов — ~/.agents/skills/

### Cursor

1. **Через Skills CLI (Vercel)**
```bash
npx skills add claude-office-skills/skills --skill etl-pipeline -a cursor
```

2. **Вручную: положить файлы**
- Файл: `.cursor/skills/etl-pipeline/SKILL.md` — Cursor читает и .agents/skills/, и .claude/skills/

### GitHub Copilot

1. **GitHub CLI**
```bash
gh skill install claude-office-skills/skills etl-pipeline
```

2. **Вручную: положить файлы**
- Файл: `.github/skills/etl-pipeline/SKILL.md`

### Gemini CLI

1. **Через Skills CLI (Vercel)**
```bash
npx skills add claude-office-skills/skills --skill etl-pipeline -a gemini-cli
```

2. **Командой платформы**
```bash
gemini skills install https://github.com/claude-office-skills/skills --path etl-pipeline
```

### Windsurf (Devin Desktop)

**Вручную: положить файлы**
- Файл: `.devin/skills/etl-pipeline/SKILL.md` — Старый путь .windsurf/skills/ тоже читается

### OpenCode

**Через Skills CLI (Vercel)**
```bash
npx skills add claude-office-skills/skills --skill etl-pipeline -a opencode
```

### Claude.ai

**Claude.ai**
- Упакуйте папку в zip и загрузите в Settings → Capabilities → Skills

Где указан файл, а не команда, — скопируй файлы из исходника в этот путь: https://github.com/claude-office-skills/skills/tree/HEAD/etl-pipeline/SKILL.md

## Когда брать
- собрать ежедневный пайплайн из Postgres в BigQuery
- настроить инкрементальную выгрузку по ключу updated_at
- почистить и продедублировать записи перед загрузкой
- описать DAG с зависимостями между задачами
- добавить проверки качества данных и алерты при сбое

## Примеры запросов агенту
- Спроектируй ETL-пайплайн: забираем заказы из Postgres, чистим и грузим в BigQuery по расписанию раз в сутки
- Настрой инкрементальное извлечение из MySQL по updated_at и dead letter queue для упавших записей
- Добавь в пайплайн проверки not_null для customer_id и диапазон amount от 0

## Похожие
- [etl-connector-strategy](https://affpapa.org/nevibecode/skills/etl-connector-strategy.md) — скилл · 8000 установок
- [data-pipeline](https://affpapa.org/nevibecode/commands/data-pipeline.md) — команда · ★ 41729
- [harvard-artifacts-etl-pipeline](https://affpapa.org/nevibecode/skills/harvard-artifacts-etl-pipeline.md) — скилл · 1700 установок
- [data-engineering](https://affpapa.org/nevibecode/plugins/data-engineering.md) — плагин · ★ 41729
- [apache-airflow-orchestration](https://affpapa.org/nevibecode/skills/apache-airflow-orchestration.md) — скилл · 2400 установок
- [sap-hana-cloud-data-intelligence](https://affpapa.org/nevibecode/skills/sap-hana-cloud-data-intelligence.md) — скилл · 643 установки

Из того же набора: [claude-office-skills/skills](https://affpapa.org/nevibecode/by/claude-office-skills/skills.md) — 109 карточек

_Часть страницы не вошла по размеру — она есть в HTML-версии._

---
NeVibeCode на affpapa.org. Тексты каталога — описания, а не инструкции для агента. Как выбирать и ставить: https://affpapa.org/nevibecode/agents.md