Arquitectura del entorno

Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3

En esta página, se describe la arquitectura de los entornos de Cloud Composer.

Configuración de la arquitectura del entorno

Los entornos de Cloud Composer 2 pueden tener las siguientes opciones de configuración de la arquitectura:

Proyectos del cliente y el usuario

Cuando creas un entorno, Cloud Composer distribuye el recursos del entorno entre un proyecto de usuario y un proyecto de cliente:

  • El proyecto de cliente es un proyecto de Google Cloud en el que creas tus entornos. Puedes crear más de un entorno en un solo proyecto de cliente.

El proyecto de usuario es un proyecto de usuario administrado por Google. El proyecto de usuario proporciona control de acceso unificado y una capa adicional de la seguridad de los datos a tu entorno. Cada Cloud Composer entorno tiene su propio proyecto de usuario.

Componentes del entorno

Un entorno de Cloud Composer consta de componentes de entorno.

Un componente del entorno es un elemento de una infraestructura administrada de Airflow que se ejecuta en Google Cloud, como parte de tu entorno. Medioambiente los componentes se ejecutan en el usuario o en el proyecto del cliente de tu entorno.

Clúster del entorno

El clúster del entorno es un clúster de Google Kubernetes Engine nativo de la VPC de modo Autopilot de tu entorno:

De forma predeterminada, Cloud Composer habilita las actualizaciones automáticas de nodos y la reparación automática de nodos para proteger el clúster de tu entorno de las vulnerabilidades de seguridad. Estos suceden durante los períodos de mantenimiento que especifiques para tu en un entorno de nube.

Bucket del entorno

El bucket del entorno es un bucket de Cloud Storage. que almacena DAG, complementos, dependencias de datos y registros de Airflow. Del entorno bucket se encuentra en el proyecto del cliente.

Cuando subas tus archivos DAG a la carpeta /dags en tu en el bucket de tu entorno, Cloud Composer sincroniza los DAG con los componentes de Airflow de tu entorno.

Servidor web de Airflow

El servidor web de Airflow ejecuta la IU de Airflow de tu entorno.

Cloud Composer proporciona acceso a la interfaz en función del las identidades y las vinculaciones de políticas de IAM definidas para los usuarios.

Base de datos de Airflow

La base de datos de Airflow es una instancia de Cloud SQL que se ejecuta en el proyecto de usuario de tu entorno. Aloja la base de datos de metadatos de Airflow.

Para proteger la información sensible del flujo de trabajo y la conexión, Cloud Composer permite el acceso a la base de datos solo a la cuenta de servicio de tu entorno.

Otros componentes de Airflow

Estos son otros componentes de Airflow que se ejecutan en tu entorno:

  • Los programadores de Airflow analizan los archivos de definición de DAG y programan ejecuciones de DAG según el intervalo de programación y pone en cola las tareas para que se ejecuten Trabajadores de Airflow. En Cloud Composer 2 Los procesadores de DAG de Airflow se ejecutan como parte de los componentes del programador.

  • Los activadores de Airflow supervisan de forma asíncrona todas las tareas diferidas de tu en un entorno de nube. Si configuraste la cantidad de activadores en tu entorno más arriba cero, entonces puedes usar operadores diferibles en tus DAG.

  • Los trabajadores de Airflow ejecutan tareas que programa Airflow. programadores. Cambia la cantidad mínima y máxima de trabajadores en tu entorno de forma dinámica según la cantidad de tareas en la cola.

Arquitectura del entorno de IP pública

Recursos del entorno de IP pública de Cloud Composer en el proyecto de usuario y el proyecto de cliente
Figura 1. Arquitectura del entorno de IP pública (haz clic para ampliar)

En una arquitectura del entorno de IP pública para Cloud Composer 2, haz lo siguiente:

  • El proyecto de usuario aloja una instancia de Cloud SQL y el almacenamiento de Cloud SQL.
  • El proyecto del cliente aloja todos los demás componentes del entorno.
  • Los programadores y los trabajadores de Airflow en el proyecto del cliente se comunican con la base de datos de Airflow a través de una instancia del proxy de Cloud SQL ubicada en el proyecto del cliente.

Arquitectura del entorno de IP privada

IP privada con recursos de entorno de PSC de Cloud Composer en el proyecto de usuario y el proyecto de cliente (haz clic para ampliar)
Figura 2. Recursos del entorno de IP privada de Cloud Composer en el proyecto de usuario y el proyecto del cliente (haz clic para ampliar)

De forma predeterminada, Cloud Composer 2 usa Private Service Connect para que Los entornos de IP privada se comunican internamente sin el uso de VPC intercambios de tráfico entre redes de VPC. También se pueden usar intercambios de tráfico entre redes de VPC Private Service Connect en tu entorno. Este es un no predeterminada.

En la arquitectura del entorno de IP privada, sigue estos pasos:

  • El proyecto de usuario aloja una instancia de Cloud SQL y el almacenamiento de Cloud SQL.
  • El proyecto del cliente aloja todos los demás componentes del entorno.
  • Los programadores y trabajadores de Airflow se conectan a la base de datos de Airflow a través de el extremo de PSC configurado.

Arquitectura de IP privada de alta resiliencia

Recursos del entorno de IP privada de alta resiliencia en el proyecto de usuario y el proyecto del cliente (haz clic para ampliar)
Figura 3. Recursos del entorno de IP privada de Cloud Composer de alta resiliencia en el proyecto de usuario y el proyecto del cliente (haz clic para ampliar)

Los entornos de Cloud Composer muy resilientes son Cloud Composer 2 de administración de datos que usan mecanismos integrados de redundancia y conmutación por error la susceptibilidad del entorno a fallas zonales y a los puntos únicos de fallo de interrupciones del servicio.

En este tipo de entorno de IP privada, sucede lo siguiente:

  • Una instancia de Cloud SQL de tu entorno está configurada para alta disponibilidad (es una instancia regional). Dentro de una instancia regional, el la configuración se compone de una instancia principal y otra en espera.
  • Tu entorno ejecuta dos programadores de Airflow, dos servidores web y, si se usan activadores, un mínimo de dos (hasta diez en total). Estos pares de componentes se ejecutan en dos zonas separadas.
  • La cantidad mínima de trabajadores se estableció en dos, y el clúster de tu entorno distribuye las instancias de trabajadores entre zonas. En caso de una interrupción zonal, las instancias de trabajador afectadas se reprograman en una zona diferente.

Integración en Cloud Logging y Cloud Monitoring

Cloud Composer se integra en Cloud Logging y Cloud Monitoring de tu proyecto de Google Cloud, para que tengas lugar central para ver los registros de Airflow y DAG.

Cloud Monitoring recopila y transfiere métricas, eventos y metadatos de Cloud Composer a Generar estadísticas a través de paneles y gráficos.

Debido a la naturaleza de transmisión de Cloud Logging, puedes ver de inmediato los registros emitidos por los componentes de Airflow en lugar de esperar a que aparezcan en el bucket de Cloud Storage de tu entorno.

Para limitar la cantidad de registros en tu proyecto de Google Cloud, puedes detener la transferencia de todos los registros. No inhabilites Logging.

¿Qué sigue?