Debido a la arquitectura de microservicios de Cloud Composer, la supervisión del funcionamiento de extremo a extremo de tu configuración de Airflow incluye varias métricas. En este instructivo, se muestra un enfoque para usar las métricas basadas en registros del conjunto de operaciones de Google Cloud a fin de configurar la supervisión y las alertas según una métrica personalizada.
Objetivos
- Implementar un DAG sencillo que se ejecute cada cierto tiempo en el entorno de Cloud Composer
- Aprovechar los registros que produce el conjunto de operaciones de Google Cloud para Cloud Composer mediante las métricas basadas en registros a fin de crear una métrica personalizada
- Configurar la supervisión y las alertas según la métrica personalizada
Costos
En este documento, usarás los siguientes componentes facturables de Google Cloud:
- Cloud Composer
Para generar una estimación de costos en función del uso previsto, usa la calculadora de precios.
Antes de comenzar
- Accede a tu cuenta de Google Cloud. Si eres nuevo en Google Cloud, crea una cuenta para evaluar el rendimiento de nuestros productos en situaciones reales. Los clientes nuevos también obtienen $300 en créditos gratuitos para ejecutar, probar y, además, implementar cargas de trabajo.
-
En la página del selector de proyectos de la consola de Google Cloud, selecciona o crea un proyecto de Google Cloud.
-
Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.
-
En la página del selector de proyectos de la consola de Google Cloud, selecciona o crea un proyecto de Google Cloud.
-
Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.
- Crea un entorno de Cloud Composer.
- Asegúrate de tener los permisos adecuados. Se requieren los siguientes permisos para acceder a los registros y las métricas de tu entorno de Cloud Composer:
- Registros y supervisión, de solo lectura:
logging.viewer
ymonitoring.viewer
- Registros (incluidos los privados), de solo lectura:
logging.privateLogViewer
- Supervisión, de lectura y escritura:
monitoring.editor
Para obtener más información, consulta Guía de control de acceso.
- Registros y supervisión, de solo lectura:
Agrega el DAG a tu entorno
Sube el siguiente DAG al depósito de Cloud Storage del entorno:
import airflow from airflow import DAG from airflow.operators.bash_operator import BashOperator from datetime import timedelta default_args = { 'retries': 1, 'retry_delay': timedelta(minutes=5), 'start_date': airflow.utils.dates.days_ago(0) } dag = DAG( 'liveness', default_args=default_args, description='liveness monitoring dag', schedule_interval=timedelta(minutes=1)) t1 = BashOperator( task_id='echo', bash_command='echo test', dag=dag, depends_on_past=False)
Espera hasta que Airflow programe el DAG. Puedes comprobar el estado en la interfaz web de Airflow.
Crea la métrica de contador basada en registros en el conjunto de operaciones de Google Cloud
Ve al Explorador de registros.
Asegúrate de que el proyecto correcto esté seleccionado en la parte superior de la página o usa el menú desplegable de la parte superior de la página para seleccionar un proyecto.
En el campo de recursos, selecciona Cloud Composer Environment (Entorno de Cloud Composer) y, luego, elige la ubicación y el nombre del entorno.
En el campo de tipo de registro, selecciona airflow-worker.
En la barra de filtros, crea un filtro a fin de mostrar solo los registros que emite el DAG en funcionamiento. Para ello, ingresa la siguiente etiqueta: label:workflow:liveness.
En la parte superior de la página, haz clic en Create Metric (Crear métrica). El Metric Editor (Editor de métricas) se muestra en el lado derecho de la página, y el panel del visor que muestra tus registros aparece en el lado izquierdo.
En el panel Metric editor (Editor de métricas), configura los siguientes campos:
- Name (Nombre): elige un nombre único entre las métricas basadas en registros de tu proyecto, por ejemplo, liveness-logs-cnt.
- Descripción: describe la métrica.
- Type (Tipo): Contador.
Haz clic en Create Metric (Crear métrica). Aparecerá la página de métricas basadas en registros.
Crea la política de alertas
En la página de métricas basadas en registros, comprueba la métrica para la que deseas crear una política y, en el menú a la derecha de la ficha de la métrica, selecciona Create alert from metric (Crear alerta a partir de métricas). Aparecerá la página Crear una política de alertas nueva.
En la página Crear una política de alertas nueva, en la sección Condiciones, haz clic en Editar. Aparece una ventana de creación de MÉTRICA con datos propagados previamente.
Ingresa un nombre para la condición (opcional).
En la sección Target (Objetivo), para Aggregator (Agregador), selecciona count (recuento).
En la sección Configuration (Configuración), para Threshold (Umbral), configura el valor según sea necesario.
Haz clic en Guardar. Aparece el panel Crear política de alertas nueva con la condición completada.
Completa las secciones Notificaciones, Documentación y Asignar un nombre a esta política de la política de alertas.
Haz clic en Guardar.
Limpia
Para evitar que se apliquen cargos a tu cuenta de Google Cloud por los recursos usados en este instructivo, borra el proyecto que contiene los recursos o conserva el proyecto y borra los recursos individuales.
- En la consola de Google Cloud, ve a la página Administrar recursos.
- En la lista de proyectos, elige el proyecto que quieres borrar y haz clic en Borrar.
- En el diálogo, escribe el ID del proyecto y, luego, haz clic en Cerrar para borrar el proyecto.
¿Qué sigue?
Si deseas obtener información sobre cómo usar un panel personalizado para ver las métricas de tu entorno de Cloud Composer, consulta Supervisa entornos y flujos de trabajo en el conjunto de operaciones de Google Cloud.