Мы используем файлы cookie для улучшения вашего опыта использования сайта. Это позволяет нам анализировать, как посетители взаимодействуют с сайтом, и делать его лучше. Продолжая использовать сайт, вы соглашаетесь на использование файлов cookie. Подробную информацию вы найдете в политике обработки персональных данных.

Apache Airflow для инженеров данных

Data Pipeline на Apache Airflow

Вендор:
Big Data School
Направление:
Big Data
Продукт:
Apache Airflow
Код курса:
AIRF
Длительность:
6 дней | 24 ак. часа

Углубленный шестидневный курс Apache Airflow поможет освоить самый популярный инструмент для оркестрации, который используют в ведущих IT-компаниях. Вы научитесь превращать хаос в данных в управляемые, автоматизированные data pipelines, став настоящим архитектором данных.

С Apache Airflow вы научитесь создавать и отслеживать сложные рабочие процессы как код. Этот практический тренинг проведет вас от создания первого DAG до продвинутых техник, включая настройку отказоустойчивых конвейеров и интеграцию с Big Data. 

Обучение Apache Airflow разработано для IT-специалистов, которые хотят систематизировать и углубить свои знания в области оркестрации данных. Программа курса по Airflow построена от простого к сложному и на 70% состоит из практики, где вы сможете применить полученные знания на реальных задачах. 

Приобретаемые знания и навыки

После прохождения курса вы сможете самостоятельно решать полный спектр задач, связанных с оркестрацией данных. От написания простых DAG до production развертывания:

  • Проектировать и писать DAG-файлы: Вы освоите синтаксис и лучшие практики создания DAG, научитесь определять зависимости между задачами, использовать шаблоны Jinja и макросы для создания динамических пайплайнов.
  • Использовать ключевые операторы и сенсоры: На практике поработаете с BashOperatorPythonOperatorPostgresOperatorExternalTaskSensor и другими, чтобы выполнять скрипты, работать с базами данных и реагировать на внешние события.
  • Управлять потоком выполнения: Глубоко разберетесь в Trigger Rules для создания сложных правил запуска задач, освоите Backfill и Catchup для перезапуска исторических данных.
  • Обмениваться данными между задачами: Научитесь использовать XComs и Variables для передачи информации и параметров между операторами в рамках одного DAG.
  • Оптимизировать и отлаживать пайплайны: Вы научитесь анализировать логи, находить «узкие» места, использовать TaskGroup для структурирования сложных DAG и применять продвинутые техники для повышения производительности.
  • Интегрировать Airflow с экосистемой Big Data: Научитесь подключать Airflow к PostgreSQL, Kafka, Spark и другим системам для построения комплексных конвейеров обработки данных.

Главная ценность для вас — это глубокое изучение технологии, которая является стандартом индустрии, и получение практических навыков, которые можно сразу же применить в работе.

Программа курса

1. Введение в Apache Airflow: Kлючевые концепции и подготовка к работе.

  • Что такое Airflow? Знакомство с платформой и её ролью в современной инженерии данных.
  • Почему Airflow? Сравнение с аналогами и конкурентами Luigi и Prefect, и разбор ключевых преимуществ.
  • История и архитектура: Краткий экскурс в историю создания и обзор основных компонентов («Китов») Airflow.

Комплексная практика: Практическое занятие по настройке рабочего образа Apache AirFlow  для дальнейшей работы.

2. Основы работы с AirFlow: От теории к первому конвейеру данных.

Архитектура и компоненты: Детальное рассмотрение верхнеуровневой архитектуры, основных компонентов и исполнителей (Executors), включая LocalExecutor.

Ключевые концепции:

  • DAG: Что такое направленный ациклический граф, его основные параметры и жизненный цикл.
  • Операторы (Operators): Обзор различных видов операторов, их параметров и принципов композиции (Composition).
  • Интерфейс: Знакомство с Web UI для мониторинга и управления рабочими процессами.

Создание первого DAG:

  • Изучение TaskFlow API для упрощенного написания кода.
  • Работа с базовыми операторами: EmptyOperator, BashOperator, PythonOperator.

Комплексная практика:

  • Написание первого DAG с использованием PythonOperator.
  • Применение переменных (Variables) и подключений (Connections) для создания динамических и переиспользуемых задач.
  • Работа с сенсорами (Sensors), включая ExternalTaskSensor, для создания зависимостей от внешних событий.

3. Расширенные возможности Airflow: Продвинутые техники и интеграции.

Управление потоком выполнения:

  • Trigger Rules: Настройка правил запуска задач в зависимости от статуса предыдущих.
  • Backfill & Catchup: Механизмы для запуска прошедших и пропущенных выполнений DAG.

Динамические пайплайны:

  • Templates & Macros: Использование шаблонов Jinja и макросов для создания гибких задач.
  • Hooks, XComs & Dynamic Tasks: Обмен данными между задачами и создание динамически генерируемых пайплайнов.
  • Интеграция с базами данных: Применение PostgresOperator для работы с PostgreSQL.

Комплексная практика:

  • Применение Trigger Rules для управления логикой ветвления в DAG.
  • Использование PostgresOperator для взаимодействия с базой данных.
  • Организация сложных DAG с помощью TaskGroup для улучшения читаемости и структурирования.
  • Реализация обмена данными между задачами с помощью XComs.
Онлайн формат обучения

Онлайн обучение - это курс, который проходит в режиме реального времени под руководством преподавателя по такому же графику как и очное обучение. Наш учебный центр может организовывать курсы только в онлайн формате или в смешанном, когда часть слушателей находится в классе очно, а часть подключается онлайн.

Занятия на большинстве наших курсов занимают 8 академических часов в день (с 10:00 до 17:00), также есть отдельные программы вечернего онлайн обучения. Чтобы наши студенты не уставали в процессе учебы, мы делаем небольшие перерывы на чай/кофе, при полнодневном обучении также есть время на полноценный обеденный перерыв.

В процессе обучения вы сможете задавать вопросы и общаться с преподавателем и остальными участниками как с помощью чата, так и голосом при наличии микрофона.

В зависимости от выбранной программы обучения, каждому участнику будет предоставлен доступ к заренее настроенной виртуальной машине с лабораторными заданиями. Для удобства мы рекомендуем слушателям подключить 2 монитора, на одном из которых будет учебный материал/трансляция преподавателя, а на другом открыт стенд для выполнения практических заданий. На части из курсов (не всех) предусмотрена запись тренинга, которую слушатели могут просмотреть, если по какой-то причине пропустили часть занятия.

Документы об окончании курса

  • Сертификат Учебного центра iqData
  • Cертификат об обучении установленного образцая

сертификат iqData об обучении на курсеСертификат установленного образца

Учились на этом курсе?

Другие курсы Data Flow и Data Engineering

NIFI3
3 дня | 24 ак. часа
TRINO
4 дня | 16 ак. часов