Проектирует Airflow DAGs: dynamic task generation, XCom для передачи данных, TaskGroups для организации. Использует sensors, hooks для интеграции с external systems. Настраивает connections и variables.

Проектирует модели данных Cassandra, оптимизированные под query-driven паттерны доступа. Реализует эффективные batch-операции и управляет жизненным циклом данных через TTL. Настраивает уровни консистентности чтения/записи для баланса задержки и надёжности.

Самостоятельно реализует Spark-пайплайны данных: оптимизирует shuffle-операции и стратегии партиционирования, реализует Structured Streaming для real-time ETL, управляет Delta Lake таблицами с ACID-транзакциями. Тюнит конфигурации Spark для памяти, параллелизма и стоимостной эффективности.

Настраивает backup для data pipeline артефактов: версионирование промежуточных данных в S3, point-in-time recovery в PostgreSQL. Реализует rollback-механизмы для ETL-процессов.

Проектирует таблицы ClickHouse для аналитических pipeline-ов: выбор engine (MergeTree, AggregatingMergeTree, ReplacingMergeTree), partitioning by date, materialized views для pre-aggregation. Оптимизирует вставку через batch inserts.

Самостоятельно реализует data pipelines с Dagster / Prefect. Оптимизирует производительность. Обеспечивает data quality.

Настраивает data catalog: интеграция с metadata sources (Hive, Glue, dbt), автоматический harvesting. Создаёт business glossary. Тегирует данные для классификации (PII, financial).

Создаёт data contracts: YAML/JSON schema definitions, quality checks, SLA metrics. Интегрирует contract validation в CI/CD. Настраивает alerting при нарушении контрактов.

Настраивает автоматический сбор lineage: интеграция Airflow/dbt/Spark с lineage-системой. Использует lineage для debugging data quality issues. Визуализирует зависимости в DataHub/OpenMetadata.

Настраивает data quality framework: Great Expectations/Soda для automated checks, custom expectations, alerting при failures. Мониторит data freshness и volume anomalies.

Проектирует DWH-компоненты: dimensional modeling по Kimball, SCD Types (1, 2, 3), aggregate tables. Настраивает incremental loading. Оптимизирует производительность через distribution keys и sort keys.

Проектирует dbt-проект: custom macros, incremental models, snapshots для SCD Type 2. Настраивает environments (dev/staging/prod). Оптимизирует модели через materialization выбор.

Самостоятельно реализует data pipelines с Delta Lake / Apache Iceberg. Оптимизирует производительность. Обеспечивает data quality.

Оптимизирует обработку через pandas/Polars: chunked reading для больших файлов, category dtype для memory, vectorized operations вместо iterrows. Мигрирует на Polars для performance-critical задач.

Оптимизирует extraction из PostgreSQL: COPY для bulk export, cursor-based pagination, partitioned tables. Настраивает logical replication для CDC. Проектирует staging-таблицы для ETL.

Добавляет custom metrics в приложение (counter, gauge, histogram). Пишет PromQL-запросы для дашбордов. Создаёт Grafana dashboards. Настраивает базовые алерты (high error rate, high latency).

Проектирует SQL-трансформации: stored procedures для complex ETL, parameterized queries, temp tables для промежуточных вычислений. Оптимизирует execution plans. Управляет transaction control.

Строит ETL-пайплайны реального времени с Kafka Streams для трансформации и обогащения данных. Реализует семантику exactly-once и мониторит consumer lag на этапах обработки.

Самостоятельно проектирует ETL-пайплайны между зонами data lake с поддержкой эволюции схем. Оптимизирует стоимость хранения через lifecycle-политики, компактификацию и многоуровневое хранение. Реализует контроль качества данных между слоями медальонной архитектуры с автоматизированной валидацией.

Проектирует стратегию индексирования для ETL-источников: partial indexes для active records, covering indexes для частых extractions. Понимает trade-off между скоростью чтения и записи в OLTP-источниках.

Проектирует schema evolution для data pipelines: backward-compatible миграции, expand-contract для zero-downtime, версионирование через Flyway/Alembic. Обрабатывает schema drift в источниках.

Оптимизирует extraction и transformation: predicate pushdown, partition pruning, выбор между JOIN и subquery. Профилирует SQL-запросы в Airflow через query tags. Оптимизирует Spark SQL execution plans.

Настраивает сетевую связность для data infrastructure: VPC peering для cross-account access, PrivateLink для managed services, security groups для data pipeline компонентов. Диагностирует connection issues.

Проектирует dimensional модели: Kimball methodology (conformed dimensions, bus matrix), Data Vault (hubs, links, satellites). Применяет SCD Type 2 с effective dates. Моделирует semi-structured данные.

Настраивает и управляет репликацией БД для data-пайплайнов: read replicas для ETL-разгрузки, schema migrations в реплицированных средах, change data capture (CDC). Понимает trade-offs консистентности, проектирует data flows с учётом replication lag.