Какой из следующих способов **наиболее эффективен для обработки больших объемов данных** в Airflow DAG?