SQL Middle ETL, ELT и Airflow спрашивают часто обновлено
Идемпотентная перезапись дневной партиции агрегатов
Условие
Задача DAG за интервал [2025-09-02, 2025-09-03) пересчитывает дневную выручку по магазинам в agg_daily_revenue. Таблица уже содержит строки за этот день от прошлого (неудачного) запуска, частично неверные. Сделайте загрузку идемпотентной: удалите строки за день интервала и вставьте свежие агрегаты из sales за этот интервал, затем выведите всю agg_daily_revenue: day, shop_id, revenue по day, shop_id. Порядок строк важен.
Как подойти
Подсказки: 1
- Сначала
DELETEза день интервала, затемINSERT ... SELECT ... GROUP BY.
Решите в тренажёре
Редактор с автотестами прямо в браузере. Можно решить спокойно, вслух или под таймером, как на собесе.