← Все работы

Backend / 2021

Data Pipeline

Пайплайн обработки данных для аналитики с Apache Airflow и Spark.

BATCH / 0001
ОТ ЗАПИСИ К НАБОРУPROCESSING

RAW

Сырые записи
IDСУММА
6на входе

CLEAN

Единый формат
IDСУММА
A0189.00
A02129.50
A0342.00
A0465.00
A05210.00
A0618.50
—после очистки

READY

Разделы по дате
2026 / 09 / 11— записи
2026 / 09 / 12— записи
—ожидание
Принимаем пакетПроверка 6 записей
ЗАПИСЬ / 01

Выберите запись, чтобы увидеть её преобразование.

ДО11.09.202689,00ПОСЛЕОжидание—

Обработка демонстрационного набора в браузере. Выберите строку RAW для просмотра деталей.

02 / О ПРОЕКТЕ

Что внутри

Data Engineer / 2021
01 / ОБЪЁМ

1TB+ данных в день

Пакетная обработка больших наборов данных с Apache Spark.

02 / ОРКЕСТРАЦИЯ

Задачи по порядку

Airflow управляет зависимостями и запускает этапы обработки по расписанию.

03 / СТРУКТУРА

Порядок в данных

Дедупликация исключает повторные записи. Партиции ускоряют работу с нужным диапазоном дат.

СЛЕДУЮЩИЙ ПРОЕКТ

SDR Video Demodulator