Cuándo usar poke, reschedule o deferrable
Tu equipo está revisando las configuraciones de sensores en tres pipelines:
- Pipeline A: Un sensor comprueba un archivo que suele llegar en los 10 segundos posteriores al inicio del Dag.
- Pipeline B: Un sensor espera una fuente de datos de un partner que llega en algún momento dentro de una ventana de 4 horas. Hay 20 sensores similares ejecutándose en paralelo.
- Pipeline C: Un sensor consulta un endpoint de API cada 2 minutos y normalmente espera 15 minutos.
¿Qué combinación de modos de sensor encaja mejor?
Este ejercicio forma parte del curso
Creación de canalizaciones de datos con Airflow
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio