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