Ejecuta una transformación SQL agregada cada dos horas que añade datos a una tabla de BigQuery. La canalización debe reintentar en caso de fallos y enviar un correo electrónico después de tres fallos consecutivos. ¿Cómo configura Cloud Composer?

La opción correcta es utilizar BigQueryInsertJobOperator en Cloud Composer, configurando retries=3 y emailonfailure=True. Este operador es ideal para ejecutar consultas SQL que insertan o transforman datos en BigQuery. Cloud Composer, al ser un orquestador de flujos de trabajo basado en Apache Airflow, permite definir reintentos (retries) y notificaciones por correo electrónico en caso de fallos (emailonfailure) directamente en la definición del DAG. BigQueryUpsertTableOperator no es un operador estándar de Airflow para BigQuery y no existe con esa funcionalidad. Las consultas programadas de BigQuery son útiles para transformaciones recurrentes, pero no ofrecen la flexibilidad de reintentos personalizados ni la lógica de notificación avanzada (como "después de tres fallos consecutivos") que se requiere, sin una integración adicional compleja. La opción de Pub/Sub y Cloud Functions añade complejidad innecesaria para una funcionalidad que Airflow ya proporciona de forma nativa.