1
Airflow / Оркестрация / DAG
1. Если нужно передать данные из одной таблицы в другую через Airflow, как вы это сделаете?
2. Можно ли передавать большие объёмы данных через XCom и если нет — какие альтернативы?
3. Airflow — оркестратор, а не ETL: как вы организуете перенос больших данных между тасками?
4. Как увеличить параллелизм задач и задействовать 16–20 ядер для вычислений в Python/DAG?
5. Как Airflow отслеживает состояние таски?
6. Как часто Airflow сканирует папку с DAG и через сколько времени отображаются изменения после обновления DAG?
7. Что происходит с данными, которые уже записываются, если вы поменяли DAG и принудительно запустили его заново?
8. Какие подходы для…