Data Lake Formation (DLF) se integra con CloudMonitor para ofrecer alertas sobre la optimización de tablas de lago. Configure reglas de alerta para un catálogo en una región específica con el fin de monitorear el estado de optimización y atender oportunamente posibles riesgos.
Creación y gestión de reglas de alerta
Inicie sesión en la consola de Cloud Monitor.
En el panel de navegación izquierdo, seleccione .
-
Haga clic en Create Alarm Rule y configure los parámetros.
Parámetro
Descripción
Product
Data Lake Formation (DLF)
Resource Range
Seleccione Instances. La regla de alerta se aplica a catálogos.
Related Resource
Haga clic en Add Instance. En la esquina superior izquierda, seleccione la región objetivo. A continuación, seleccione los catálogos que desea monitorear y haga clic en OK.
Rule Description
Haga clic en Add Rule > Simple Metric o Combined Metrics para abrir el panel Configure Rule Description.
Métricas de Cloud Monitor
-
compaction_latency_between_latest_compacted_and_uncompacted_commit
Definición: Mide la diferencia de tiempo entre el commit compactado más reciente y el commit no compactado más reciente.
Semántica: Indica el intervalo de tiempo de datos no compactados en el sistema.
-
Casos de uso:
Evaluar el progreso de actualización de datos.
Un valor alto indica que la tarea de compactación más reciente se está rezagando respecto al progreso de escritura.
Nota: Esta métrica mide el retraso de una tarea de compactación en relación con el progreso de escritura más reciente (la brecha de actualización), no el tiempo de espera de un dato específico.
-
compaction_latency_earliest_uncompacted_commit
Definición: Mide la latencia desde el momento del commit de la instantánea no compactada más antigua hasta la hora actual del sistema.
Semántica: Indica el retraso de las tareas de compactación a nivel de programación. Representa la duración que el lote más antiguo de datos confirmados ha estado en espera de compactación.
-
Casos de uso:
Monitorear la capacidad de respuesta del sistema de programación.
Solucionar problemas por insuficiencia de recursos de compactación.
Nota: En escenarios de commits de alta frecuencia, esta métrica puede ser menor a la esperada, ya que excluye el tiempo dedicado a la escritura de datos.
-
compaction_latency_earliest_uncompacted_file
Definición: Mide la latencia desde la creación del archivo de datos no compactado más antiguo hasta la hora actual del sistema.
Semántica: Refleja la actualización de datos de extremo a extremo, desde el momento en que los datos se almacenan físicamente hasta que se ponen en cola para su compactación.
-
Casos de uso:
Escenarios que requieren un monitoreo estricto de la actualización de datos.
Escenarios de escritura de flujos de ventana larga o importación por lotes grandes con intervalos de checkpoint prolongados.
Nota: Esta métrica incluye los tiempos de escritura de datos ascendentes y de checkpoint. Su valor suele ser mayor que la latencia de
compaction_latency_earliest_uncompacted_commity proporciona una medida más precisa de la antigüedad de los datos físicos más viejos.
Puede llamar a la operación de API GetTableCompactionInfo para consultar la marca de tiempo específica.
Cuando no existen datos pendientes de compactación, todas las métricas de latencia de compactación son 0.
Estas métricas solo aplican a tablas de clave principal de Paimon en las que se habilitó la optimización de tablas de lago mediante la configuración
write-only=true. Esta opción está habilitada de forma predeterminada en el servicio totalmente administrado de DLF.
Configuraciones de alerta recomendadas y ejemplos
|
Caso de uso |
Configuración de alerta recomendada |
|
Monitoreo de tablas de clave principal con actualizaciones frecuentes |
Tipo de métrica: Combined Metrics (activa una alerta si se cumple alguna condición)
Dimensión: Tabla |
|
Monitoreo a nivel de base de datos o catálogo |
Tipo de métrica: Simple Metric
Dimensión: Base de datos o catálogo (dimensión no especificada) |
Ejemplo de regla de alerta
|
Parámetro |
Ejemplo |
|
Nombre de la regla |
Alerta de latencia de compactación |
|
Tipo de métrica |
Combined Metrics |
|
Nivel de alerta |
Advertencia (Warn) |
|
Condición de alerta multimétrica |
|
|
Seleccionar dimensión |
Tabla |
|
Relación entre métricas |
Activar una alerta si se cumple cualquier condición |
|
Condición de activación |
Durante un periodo consecutivo de 1 minuto |