Собесов

DataLearn DE-101: Airflow DAG для ежедневной загрузки заказов

Кейсы и метрикиOrchestrationСредняяMiddle

Условие

Нужно каждый день в 03:00 МСК выгружать новые заказы из Postgres за вчерашний день, складывать сырьё в S3, потом грузить в Snowflake и пересчитывать витрину mart_orders_daily. Напишите Airflow DAG. Опишите, как обрабатываются ошибки и backfill.

Хочешь увидеть разбор?

Зарегистрируйся бесплатно — откроется развёрнутое решение этой задачи и ещё 4 на выбор.

Зарегистрироваться и увидеть разбор
Уже есть аккаунт? Войти