

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

# Métriques de l'environnement Apache Airflow dans CloudWatch
<a name="access-metrics-cw"></a>

Apache Airflow v2 et v3 sont déjà configurés pour collecter et envoyer à Amazon des [métriques StatsD](https://github.com/etsy/statsd) pour un environnement Amazon Managed Workflows for Apache Airflow. CloudWatch La liste complète des métriques envoyées par Apache Airflow est disponible sur la page [Metrics du guide](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html) de référence d'*Apache Airflow*. Cette page décrit les métriques Apache Airflow disponibles dans la CloudWatch console et explique comment y accéder. CloudWatch 

**Contents**
+ [Conditions](#access-metrics-cw-terms)
+ [Dimensions](#metrics-dimensions)
+ [Accès aux métriques dans la CloudWatch console](#access-metrics-cw-console)
+ [Les métriques d'Apache Airflow sont disponibles dans CloudWatch](#available-metrics-cw)
  + [Compteurs Apache Airflow](#counters-metrics)
  + [Jauges Apache Airflow](#gauges-metrics)
  + [Minuteries Apache Airflow](#timers-metrics)
+ [Choix des indicateurs à signaler](#choosing-metrics)
+ [Quelle est la prochaine étape ?](#mwaa-metrics202-next-up)

## Conditions
<a name="access-metrics-cw-terms"></a>

**Namespace**  
Un espace de noms est un conteneur pour les CloudWatch métriques d'un AWS service. *Pour Amazon MWAA, l'espace de noms est AmazonMWAA.*

**CloudWatch métriques**  
Une CloudWatch métrique représente un ensemble chronologique de points de données spécifiques à CloudWatch.

**Métriques d'Apache Airflow**  
Les [métriques](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html ) spécifiques à Apache Airflow.

**Dimension**  
Une dimension est une name/value paire qui fait partie de l'identité d'une métrique.

**Unit**  
Une statistique possède une unité de mesure. Pour Amazon MWAA, les unités incluent le *nombre*, les *secondes* et les *millisecondes*. Pour Amazon MWAA, les unités sont définies en fonction des unités indiquées dans les métriques Airflow d'origine.

## Dimensions
<a name="metrics-dimensions"></a>

Cette section décrit le regroupement de CloudWatch *dimensions* pour les métriques Apache Airflow dans. CloudWatch


| Dimension | Description | 
| --- | --- | 
|  JOUR  |  Indique un nom de DAG Apache Airflow spécifique.  | 
|  Nom de fichier DAG  |  Indique un nom de fichier DAG Apache Airflow spécifique.  | 
|  Fonction  |  Cette dimension est utilisée pour améliorer le regroupement des métriques dans CloudWatch.  | 
|  Tâche  |  Indique une tâche Apache Airflow exécutée par le planificateur. A toujours une valeur de`Job`.  | 
|  Opérateur  |  Indique un opérateur Apache Airflow spécifique.  | 
|  Pool  |  Indique un pool de travailleurs Apache Airflow spécifique.  | 
|  Sous-tâche  |  Indique une tâche Apache Airflow spécifique.  | 
|  HostName  |  Indique le nom d'hôte d'un processus Apache Airflow spécifique en cours d'exécution.  | 

## Accès aux métriques dans la CloudWatch console
<a name="access-metrics-cw-console"></a>

Cette section décrit comment accéder aux métriques de performance CloudWatch pour un DAG spécifique.

**Pour accéder aux indicateurs de performance d'une dimension**

1. Ouvrez la [page Metrics](https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~()) sur la CloudWatch console.

1. Sélectionnez votre Région AWS.

1. Choisissez l'espace de noms **AmazonMWAA**.

1. Dans l'onglet **Toutes les mesures**, sélectionnez une dimension. Par exemple, *DAG, Environnement*.

1. Choisissez une CloudWatch métrique pour une dimension. Par exemple, *TaskInstanceSuccesses* ou *TaskInstanceDuration*. Choisissez **Représenter graphiquement tous les résultats de recherche**.

1. Choisissez l'onglet **Graphed metrics** pour accéder aux statistiques de performance des métriques Apache Airflow, *telles que DAG, Environment,* Task.

## Les métriques d'Apache Airflow sont disponibles dans CloudWatch
<a name="available-metrics-cw"></a>

Cette section décrit les métriques et les dimensions d'Apache Airflow envoyées à. CloudWatch

### Compteurs Apache Airflow
<a name="counters-metrics"></a>

*Les métriques Apache Airflow présentées dans cette section contiennent des données sur les compteurs [Apache Airflow](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#counters).*


| CloudWatch métrique | Métrique Apache Airflow | Unit | Dimension | 
| --- | --- | --- | --- | 
|  SLAMissed  Disponible uniquement pour Apache Airflow v2.4.3 à v2.10.3.   |  sla\$1missed  |  Nombre  |  Fonction, planificateur  | 
|  Échoué SLACallback  Disponible uniquement pour Apache Airflow v2.4.3 à v2.10.3.   |  sla\$1callback\$1notification\$1failure  |  Nombre  |  Fonction, planificateur  | 
|  Mises à jour  Disponible pour Apache Airflow v2.6.3 et versions ultérieures.   |  jeu de données.mises à jour  |  Nombre  |  Fonction, planificateur  | 
|  Orphelin  Disponible pour Apache Airflow v2.6.3 et versions ultérieures.   |  jeu de données orphelin  |  Nombre  |  Fonction, planificateur  | 
|  FailedCeleryTaskExecution  Disponible pour Apache Airflow v2.4.3 et versions ultérieures.   |  celery.execute\$1command.failure  |  Nombre  |  Fonction, céleri  | 
|  FilePathQueueUpdateCount  Disponible pour Apache Airflow v2.6.3 et versions ultérieures.   |  dag\$1processing.file\$1path\$1queue\$1update\$1count  |  Nombre  |  Fonction, planificateur  | 
|  CriticalSectionBusy  |  scheduler.critical\$1section\$1busy  |  Nombre  |  Fonction, planificateur  | 
|  DagBagSize  |  taille\$1du\$1sac  |  Nombre  |  Fonction, traitement DAG  | 
|  DagCallbackExceptions  |  dag.callback\$1exceptions  |  Nombre  |  DAG, Tous  | 
|  SLAEmailTentatives ratées  Non disponible pour Apache Airflow v3.0.6 et versions ultérieures.   |  échec de notification par e-mail  |  Nombre  |  Fonction, planificateur  | 
|  TaskInstanceFinished  |  ti.finish. \$1day\$1id\$1. \$1identifiant de tâche\$1. \$1état\$1  |  Nombre  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1 État, \$1état\$1  | 
|  JobEnd  |  \$1job\$1name\$1 \$1fin  |  Nombre  |  Job, \$1job\$1name\$1  | 
|  JobHeartbeatFailure  |  \$1job\$1name\$1 \$1heartbeat\$1failure  |  Nombre  |  Job, \$1job\$1name\$1  | 
|  JobStart  |  \$1nom\$1tâche\$1 \$1démarrer  |  Nombre  |  Job, \$1job\$1name\$1  | 
|  ManagerStalls  |  dag\$1processing.manager\$1stalls  |  Nombre  |  Fonction, traitement DAG  | 
|  OperatorFailures  |  opérateur\$1failures\$1 \$1nom\$1opérateur\$1  |  Nombre  |  Opérateur, \$1operator\$1name\$1  | 
|  OperatorSuccesses  |  operator\$1successes\$1 \$1nom\$1opérateur\$1  |  Nombre  |  Opérateur, \$1operator\$1name\$1  | 
|  OtherCallbackCount  Disponible dans Apache Airflow v2.6.3 et versions ultérieures.   |  dag\$1processing.other\$1callback\$1count  |  Nombre  |  Fonction, planificateur  | 
|  Processus  |  dag\$1processing.processes  |  Nombre  |  Fonction, traitement DAG  | 
|  SchedulerHeartbeat  |  scheduler\$1heartbeat  |  Nombre  |  Fonction, planificateur  | 
|  StartedTaskInstances  |  ti.start. \$1day\$1id\$1. \$1identifiant de tâche\$1  |  Nombre  |  DAG, Tous Tâche, tout  | 
|  SlaCallbackCount  |  dag\$1processing.sla\$1callback\$1count  Disponible pour Apache Airflow v2.6.3 et versions ultérieures.   |  Nombre  |  Fonction, planificateur  | 
|  TasksKilledExternally  |  scheduler.tasks.killed\$1external  |  Nombre  |  Fonction, planificateur  | 
|  TaskTimeoutError  |  celery.task\$1timeout\$1error  |  Nombre  |  Fonction, céleri  | 
|  TaskInstanceCreatedUsingOperator  |  task\$1instance\$1created- \$1nom\$1opérateur\$1  |  Nombre  |  Opérateur, \$1operator\$1name\$1  | 
|  TaskInstancePreviouslySucceeded  |  précédemment \$1réussi  |  Nombre  |  DAG, Tous Tâche, tout  | 
|  TaskInstanceFailures  |  ti\$1failures  |  Nombre  |  DAG, Tous Tâche, tout  | 
|  TaskInstanceSuccesses  |  ti\$1success  |  Nombre  |  DAG, Tous Tâche, tout  | 
|  TaskRemovedFromDAG  |  task\$1removed\$1from\$1dag. \$1day\$1id\$1  |  Nombre  |  DAG, \$1day\$1id\$1  | 
|  TaskRestoredToDAG  |  task\$1restored\$1to\$1day. \$1day\$1id\$1  |  Nombre  |  DAG, \$1day\$1id\$1  | 
|  TriggersSucceeded  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  déclencheurs réussis  |  Nombre  |  Fonction, déclencheur  | 
|  TriggersFailed  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  déclencheurs. échec  |  Nombre  |  Fonction, déclencheur  | 
|  TriggersBlockedMainThread  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  triggers. blocked\$1main\$1thread  |  Nombre  |  Fonction, déclencheur  | 
|  TriggerHeartbeat  Disponible pour Apache Airflow v2.8.1 et versions ultérieures.   |  déclencheur du battement de cœur  |  Nombre  |  Fonction, déclencheur  | 
|  TaskInstanceCreatedUsingOperator  |  airflow.task\$1instance\$1created\$1 `{operator_name}`  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  Nombre  |  Opérateur, `{operator_name}`  | 
|  ZombiesKilled  |  zombies tués  |  Nombre  |  DAG, Tous Tâche, tout  | 

### Jauges Apache Airflow
<a name="gauges-metrics"></a>

*Les métriques Apache Airflow présentées dans cette section contiennent des données sur les jauges [Apache Airflow](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#gauges).*


| CloudWatch métrique | Métrique Apache Airflow | Unit | Dimension | 
| --- | --- | --- | --- | 
|  DAGFileRefreshError  |  dag\$1file\$1refresh\$1error  |  Nombre  |  Fonction, traitement DAG  | 
|  ImportErrors  |  dag\$1processing.import\$1errors  |  Nombre  |  Fonction, traitement DAG  | 
|  ExceptionFailures  |  smart\$1sensor\$1operator.exception\$1failures  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  ExecutedTasks  |  smart\$1sensor\$1operator.tâches exécutées  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  InfraFailures  |  smart\$1sensor\$1operator.infra\$1failures  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  LoadedTasks  |  smart\$1sensor\$1operator.loaded\$1tasks  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  TotalParseTime  |  dag\$1processing.total\$1parse\$1time  |  Secondes  |  Fonction, traitement DAG  | 
|  TriggeredDagRuns  Disponible dans Apache Airflow v2.6.3 et versions ultérieures.   |  jeu de données .triggered\$1dagruns  |  Nombre  |  Fonction, planificateur  | 
|  TriggersRunning  Disponible dans Apache Airflow v2.7.2 et versions ultérieures.   |  déclencheurs. Exécution. *\$1hostname\$1*  |  Nombre  |  Fonction, déclencheur HostName, *\$1hostname\$1*  | 
|  PoolDeferredSlots  Disponible dans Apache Airflow v2.7.2 et versions ultérieures.   |  pool.deferred\$1slots. `{pool_name}`  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  DAGFileProcessingLastRunSecondsAgo  |  dag\$1processing.last\$1run. Il y a quelques secondes. \$1dag\$1filename\$1  |  Secondes  |  Nom du fichier DAG, \$1dag\$1filename\$1  | 
|  OpenSlots  |  exécuteur.open\$1slots  |  Nombre  |  Fonction, exécuteur  | 
|  OrphanedTasksAdopted  |  scheduler.orphaned\$1tasks.adopted  |  Nombre  |  Fonction, planificateur  | 
|  OrphanedTasksCleared  |  scheduler.orphaned\$1tasks.cleared  |  Nombre  |  Fonction, planificateur  | 
|  PokedExceptions  |  smart\$1sensor\$1operator.poked\$1exception  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  PokedSuccess  |  smart\$1sensor\$1operator.poked\$1success  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  PokedTasks  |  smart\$1sensor\$1operator.poked\$1tasks  |  Nombre  |  Fonction, opérateur de capteur intelligent  | 
|  PoolFailures  |  pool.open\$1slots. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  PoolStarvingTasks  |  pool.starving\$1tasks. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  PoolOpenSlots  |  pool.open\$1slots. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  PoolQueuedSlots  |  pool.queued\$1slots. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  PoolRunningSlots  |  pool.running\$1slots. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  ProcessorTimeouts  |  dag\$1processing.processor\$1timeouts  |  Nombre  |  Fonction, traitement DAG  | 
|  QueuedTasks  |  executor.queued\$1tasks  |  Nombre  |  Fonction, exécuteur  | 
|  RunningTasks  |  exécuteur.running\$1tasks  |  Nombre  |  Fonction, exécuteur  | 
|  TasksExecutable  |  scheduler.tasks.exécutable  |  Nombre  |  Fonction, planificateur  | 
|  TasksPending  Ne s'applique pas à Apache Airflow v2.2 et versions ultérieures.   |  scheduler.tasks.pending  |  Nombre  |  Fonction, planificateur  | 
|  TasksRunning  |  scheduler.tasks.running  |  Nombre  |  Fonction, planificateur  | 
|  TasksStarving  |  scheduler.tasks.starving  |  Nombre  |  Fonction, planificateur  | 
|  TasksWithoutDagRun  |  scheduler.tasks.without\$1dagrun  |  Nombre  |  Fonction, planificateur  | 
|  DAGFileProcessingLastNumOfDbQueries  Disponible dans Apache Airflow v2.10.1 et versions ultérieures.  |  dag\$1processing.last\$1num\$1of\$1db\$1queries. \$1dag\$1filename\$1  |  Nombre  |  Nom du fichier DAG, \$1dag\$1filename\$1  | 
|  PoolScheduledSlots  Disponible dans Apache Airflow v2.10.1 et versions ultérieures.   |  pool.scheduled\$1slots. \$1nom\$1piscine\$1  |  Nombre  |  Piscine, \$1pool\$1name\$1  | 
|  TaskCpuUsage  Disponible dans Apache Airflow v2.10.1 et versions ultérieures.  |  utilisation du processeur. \$1day\$1id\$1. \$1identifiant de tâche\$1  |  Pourcentage  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1  | 
|  TaskMemoryUsage  Disponible dans Apache Airflow v2.10.1 et versions ultérieures.  |  mem.usage. \$1day\$1id\$1. \$1identifiant de tâche\$1  |  Pourcentage  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1  | 

### Minuteries Apache Airflow
<a name="timers-metrics"></a>

*Les métriques d'Apache Airflow présentées dans cette section contiennent des données sur les temporisateurs d'[Apache Airflow](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#timers).*


| CloudWatch métrique | Métrique Apache Airflow | Unit | Dimension | 
| --- | --- | --- | --- | 
|  Collectez DBDags  |  collecte\$1db\$1dags  |  Millisecondes  |  Fonction, traitement DAG  | 
|  CriticalSectionDuration  |  scheduler.critical\$1section\$1duration  |  Millisecondes  |  Fonction, planificateur  | 
|  CriticalSectionQueryDuration  Disponible pour Apache Airflow v2.5.1 et versions ultérieures.   |  scheduler.critical\$1section\$1query\$1duration  |  Millisecondes  |  Fonction, planificateur  | 
|  DAGDependencyVérifiez  |  dagrun.dependency-check. \$1day\$1id\$1  |  Millisecondes  |  DAG, \$1day\$1id\$1  | 
|  DAGDurationÉchoué  |  dagrun.duration. a échoué. \$1day\$1id\$1  |  Millisecondes  |  DAG, \$1day\$1id\$1  | 
|  DAGDurationSuccès  |  dagrun.duration.success. \$1day\$1id\$1  |  Millisecondes  |  DAG, \$1day\$1id\$1  | 
|  DAGFileProcessingLastDuration  |  dag\$1processing.last\$1duration. \$1dag\$1filename\$1  |  Secondes  |  Nom du fichier DAG, \$1dag\$1filename\$1  | 
|  DAGScheduleRetard  |  dagrun.schedule\$1delay. \$1day\$1id\$1  |  Millisecondes  |  DAG, \$1day\$1id\$1  | 
|  FirstTaskSchedulingDelay  |  dagrun. \$1dag\$1id\$1 .first\$1task\$1scheduling\$1delay  |  Millisecondes  |  DAG, \$1day\$1id\$1  | 
|  SchedulerLoopDuration  Disponible pour Apache Airflow v2.5.1 et versions ultérieures.   |  scheduler.scheduler\$1loop\$1duration  |  Millisecondes  |  Fonction, planificateur  | 
|  TaskInstanceDuration  |  jour. \$1day\$1id\$1. \$1task\$1id\$1 .durée  |  Millisecondes  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1  | 
|  TaskInstanceQueuedDuration  |  jour. `{dag_id}`. `{task_id}`.queued\$1duration  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  Millisecondes  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1  | 
|  TaskInstanceScheduledDuration  Disponible pour Apache Airflow v2.7.2 et versions ultérieures.   |  jour. `{dag_id}`. `{task_id}`.durée\$1planifiée  |  Millisecondes  |  DAG, \$1day\$1id\$1 Tâche, \$1task\$1id\$1  | 

## Choix des indicateurs à signaler
<a name="choosing-metrics"></a>

[Vous pouvez choisir les métriques Apache Airflow qui sont émises ou bloquées par Apache Airflow CloudWatch, à l'aide des options de configuration Amazon MWAA suivantes :](configuring-env-variables.md)
+ **`metrics.metrics_allow_list`**— Une liste de préfixes séparés par des virgules que vous pouvez utiliser pour sélectionner les métriques vers CloudWatch lesquelles votre environnement émet. Utilisez cette option si vous souhaitez qu'Apache Airflow n'envoie pas toutes les métriques disponibles et sélectionne un sous-ensemble d'éléments. Par exemple, `scheduler,executor,dagrun`.
+ **`metrics.metrics_block_list`**— Une liste de préfixes séparés par des virgules pour filtrer les métriques commençant par les éléments de la liste. Par exemple, `scheduler,executor,dagrun`.

Si vous configurez les deux `metrics.metrics_allow_list` et`metrics.metrics_block_list`, Apache Airflow les ignore. `metrics.metrics_block_list` Si vous configurez `metrics.metrics_block_list` mais non`metrics.metrics_allow_list`, Apache Airflow filtre les éléments que vous spécifiez. `metrics.metrics_block_list`

**Note**  
Les options `metrics.metrics_block_list` de configuration `metrics.metrics_allow_list` et s'appliquent uniquement à Apache Airflow v2.6.3 et versions ultérieures. Pour les versions précédentes d'Apache Airflow, utilisez `metrics.statsd_allow_list` et `metrics.statsd_block_list` à la place.

## Quelle est la prochaine étape ?
<a name="mwaa-metrics202-next-up"></a>
+ Découvrez le fonctionnement de l'API Amazon MWAA utilisé pour publier les indicateurs de santé de l'environnement sur [PublishMetrics](https://docs.aws.amazon.com/mwaa/latest/API/API_PublishMetrics.html).