

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

# Metriche dell'ambiente Apache Airflow in CloudWatch
<a name="access-metrics-cw"></a>

Apache Airflow v2 e v3 sono già configurati per raccogliere e inviare ad Amazon i parametri [StatSD](https://github.com/etsy/statsd) per un ambiente Amazon Managed Workflows for Apache Airflow. CloudWatch *L'elenco completo delle metriche inviate da Apache Airflow è disponibile nella pagina Metriche [della](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html) guida di riferimento di Apache Airflow.* Questa pagina descrive le metriche di Apache Airflow disponibili CloudWatch in Apache Airflow e come accedervi nella console. CloudWatch 

**Contents**
+ [Termini](#access-metrics-cw-terms)
+ [Dimensioni](#metrics-dimensions)
+ [Accesso alle metriche nella console CloudWatch](#access-metrics-cw-console)
+ [Metriche Apache Airflow disponibili in CloudWatch](#available-metrics-cw)
  + [Contatori Apache Airflow](#counters-metrics)
  + [Misuratori Apache Airflow](#gauges-metrics)
  + [Timer Apache Airflow](#timers-metrics)
+ [Scelta delle metriche da segnalare](#choosing-metrics)
+ [Fasi successive](#mwaa-metrics202-next-up)

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

**Namespace**  
Un namespace è un contenitore per le metriche di un servizio. CloudWatch AWS *Per Amazon MWAA, lo spazio dei nomi è AmazonMWAA.*

**CloudWatch metriche**  
Una CloudWatch metrica rappresenta un insieme ordinato nel tempo di punti dati specifici per. CloudWatch

**Metriche Apache Airflow**  
Le [metriche](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html ) specifiche di Apache Airflow.

**Dimensione**  
Una dimensione è una name/value coppia che fa parte dell'identità di una metrica.

**Unità**  
Una statistica ha un'unità di misura. *Per Amazon MWAA, le unità includono *Count*, *Secondi* e Millisecondi.* Per Amazon MWAA, le unità vengono impostate in base alle unità nelle metriche Airflow originali.

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

Questa sezione descrive il raggruppamento delle CloudWatch *dimensioni* per le metriche di Apache Airflow in. CloudWatch


| Dimensione | Description | 
| --- | --- | 
| DAG | Indica un nome DAG Apache Airflow specifico. | 
| Nome del file DAG | Indica un nome di file Apache Airflow DAG specifico. | 
| Funzione | Questa dimensione viene utilizzata per migliorare il raggruppamento delle metriche in. CloudWatch | 
| Processo | Indica un job Apache Airflow eseguito dallo scheduler. Ha sempre un valore di. `Job` | 
| Operatore | Indica un operatore Apache Airflow specifico. | 
| Pool | Indica un pool di lavoratori Apache Airflow specifico. | 
| Operazione | Indica un'attività specifica di Apache Airflow. | 
| HostName | Indica il nome host per uno specifico processo Apache Airflow in esecuzione. | 

## Accesso alle metriche nella console CloudWatch
<a name="access-metrics-cw-console"></a>

Questa sezione descrive come accedere alle metriche delle prestazioni CloudWatch per un DAG specifico.

**Per accedere alle metriche delle prestazioni per una dimensione**

1. Apri la [pagina Metriche](https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~()) sulla console. CloudWatch 

1. Seleziona il tuo. Regione AWS

1. Scegli lo spazio dei nomi **AmazonMWAA**.

1. Nella scheda **Tutte le metriche**, seleziona una dimensione. Ad esempio, *DAG, Environment*.

1. Scegli una CloudWatch metrica per una dimensione. Ad esempio *TaskInstanceSuccesses* o *TaskInstanceDuration*. Scegli **Grafica tutti i risultati della ricerca**.

1. *Scegli la scheda **Metriche grafiche** per accedere alle statistiche sulle prestazioni per le metriche di Apache Airflow, come DAG, Environment, Task.*

## Metriche Apache Airflow disponibili in CloudWatch
<a name="available-metrics-cw"></a>

Questa sezione descrive le metriche e le dimensioni di Apache Airflow inviate a. CloudWatch

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

[https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#counters](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#counters)


| CloudWatch parametro | Metrica Apache Airflow | Unità | Dimensione | 
| --- | --- | --- | --- | 
| SLAMissed Disponibile solo per Apache Airflow dalla versione 2.4.3 alla versione 2.10.3.  | sla\_missed | Conteggio | Funzione, Scheduler | 
| Fallito SLACallback Disponibile solo per Apache Airflow dalla versione 2.4.3 alla versione 2.10.3.  | sla\_callback\_notification\_failure | Conteggio | Funzione, Scheduler | 
| Aggiornamenti Disponibile per Apache Airflow v2.6.3 e versioni successive.  | dataset.updates | Conteggio | Funzione, Scheduler | 
| Orfano Disponibile per Apache Airflow v2.6.3 e versioni successive.  | dataset.orphaned | Conteggio | Funzione, Scheduler | 
| FailedCeleryTaskExecution Disponibile per Apache Airflow v2.4.3 e versioni successive.  | celery.execute\_command.failure | Conteggio | Funzione, Celery | 
| FilePathQueueUpdateCount Disponibile per Apache Airflow v2.6.3 e versioni successive.  | dag\_processing.file\_path\_queue\_update\_count | Conteggio | Funzione, Scheduler | 
| CriticalSectionBusy | scheduler.critical\_section\_busy | Conteggio | Funzione, Scheduler | 
| DagBagSize | dagbag\_size | Conteggio | Funzione, elaborazione DAG | 
| DagCallbackExceptions | dag.callback\_exceptions | Conteggio | DAG, Tutti | 
| Tentativi falliti SLAEmail Non disponibile per Apache Airflow v3.0.6 e versioni successive.  | sla\_email\_notification\_failure | Conteggio | Funzione, Scheduler | 
| TaskInstanceFinished | ti.finish. {id\_giorno}. {id\_attività}. {stato} | Conteggio | GIORNO, {dag\_id}<br />Attività, {task\_id}<br />Stato, {state} | 
| JobEnd | {job\_name} \_end | Conteggio | Job, {job\_name} | 
| JobHeartbeatFailure | {job\_name} \_heartbeat\_failure | Conteggio | Job, {job\_name} | 
| JobStart | {job\_name} \_inizio | Conteggio | Job, {job\_name} | 
| ManagerStalls | dag\_processing.manager\_stalls | Conteggio | Funzione, elaborazione DAG | 
| OperatorFailures | operator\_failures\_ {operator\_name} | Conteggio | Operatore, {operator\_name} | 
| OperatorSuccesses | operator\_successes\_ {operator\_name} | Conteggio | Operatore, {operator\_name} | 
| OtherCallbackCount Disponibile in Apache Airflow v2.6.3 e versioni successive.  | dag\_processing.other\_callback\_count | Conteggio | Funzione, Scheduler | 
| Processes | dag\_processing.processes | Conteggio | Funzione, elaborazione DAG | 
| SchedulerHeartbeat | scheduler\_heartbeat | Conteggio | Funzione, Scheduler | 
| StartedTaskInstances | ti.start. {id\_giorno}. {id\_attività} | Conteggio | DAG, Tutti<br />Compito, tutti | 
| SlaCallbackCount | dag\_processing.sla\_callback\_count Disponibile per Apache Airflow v2.6.3 e versioni successive.  | Conteggio | Funzione, Scheduler | 
| TasksKilledExternally | scheduler.tasks.killed\_externally | Conteggio | Funzione, Scheduler | 
| TaskTimeoutError | celery.task\_timeout\_error | Conteggio | Funzione, Celery | 
| TaskInstanceCreatedUsingOperator | task\_instance\_created- {operator\_name} | Conteggio | Operatore, {operator\_name} | 
| TaskInstancePreviouslySucceeded | precedente\_successo\_successo | Conteggio | DAG, Tutti<br />Compito, tutti | 
| TaskInstanceFailures | ti\_failures | Conteggio | DAG, Tutti<br />Compito, tutti | 
| TaskInstanceSuccesses | ti\_successes | Conteggio | DAG, Tutti<br />Compito, tutti | 
| TaskRemovedFromDAG | task\_removed\_da\_dag. {id\_giorno} | Conteggio | DAG, {dag\_id} | 
| TaskRestoredToDAG | task\_ripristinato\_dag. {id\_giorno} | Conteggio | DAG, {dag\_id} | 
| TriggersSucceeded Disponibile per Apache Airflow v2.7.2 e versioni successive.  | triggers.riuscito | Conteggio | Funzione, Trigger | 
| TriggersFailed Disponibile per Apache Airflow v2.7.2 e versioni successive.  | triggers.failed | Conteggio | Funzione, Trigger | 
| TriggersBlockedMainThread Disponibile per Apache Airflow v2.7.2 e versioni successive.  | triggers.blocked\_main\_thread | Conteggio | Funzione, Trigger | 
| TriggerHeartbeat Disponibile per Apache Airflow v2.8.1 e versioni successive.  | triggerer\_heartbeat | Conteggio | Funzione, Triggerer | 
| TaskInstanceCreatedUsingOperator | airflow.task\_instance\_created\_ `{operator_name}` Disponibile per Apache Airflow v2.7.2 e versioni successive.  | Conteggio | Operatore, `{operator_name}` | 
| ZombiesKilled | zombie uccisi | Conteggio | DAG, Tutti<br />Compito, tutti | 

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

[https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#gauges](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#gauges)


| CloudWatch parametro | Metrica Apache Airflow | Unità | Dimensione | 
| --- | --- | --- | --- | 
| DAGFileRefreshError | dag\_file\_refresh\_error | Conteggio | Funzione, elaborazione DAG | 
| ImportErrors | dag\_processing.import\_errors | Conteggio | Funzione, elaborazione DAG | 
| ExceptionFailures | smart\_sensor\_operator.exception\_failures | Conteggio | Funzione, Smart Sensor Operator | 
| ExecutedTasks | smart\_sensor\_operator.executed\_tasks | Conteggio | Funzione, Smart Sensor Operator | 
| InfraFailures | smart\_sensor\_operator.infra\_failures | Conteggio | Funzione, Smart Sensor Operator | 
| LoadedTasks | smart\_sensor\_operator.loaded\_tasks | Conteggio | Funzione, Smart Sensor Operator | 
| TotalParseTime | dag\_processing.total\_parse\_time | Secondi | Funzione, elaborazione DAG | 
| TriggeredDagRuns Disponibile in Apache Airflow v2.6.3 e versioni successive.  | dataset.triggered\_dagruns | Conteggio | Funzione, Scheduler | 
| TriggersRunning Disponibile in Apache Airflow v2.7.2 e versioni successive.  | triggers.running. {{{hostname}}} | Conteggio | Funzione, grilletto<br />HostName, {{{hostname}}} | 
| PoolDeferredSlots Disponibile in Apache Airflow v2.7.2 e versioni successive.  | pool.deferred\_slots. `{pool_name}` | Conteggio | Piscina, {pool\_name} | 
| DAGFileProcessingLastRunSecondsAgo | dag\_processing.last\_run.seconds\_ago. {nome\_file} | Secondi | Nome file DAG, {dag\_filename} | 
| OpenSlots | esecutore.open\_slots | Conteggio | Funzione, Executor | 
| OrphanedTasksAdopted | scheduler.orphaned\_tasks.adopted | Conteggio | Funzione, Scheduler | 
| OrphanedTasksCleared | scheduler.orphaned\_tasks.cleared | Conteggio | Funzione, Scheduler | 
| PokedExceptions | smart\_sensor\_operator.poked\_exception | Conteggio | Funzione, Smart Sensor Operator | 
| PokedSuccess | smart\_sensor\_operator.poked\_success | Conteggio | Funzione, Smart Sensor Operator | 
| PokedTasks | smart\_sensor\_operator.poked\_tasks | Conteggio | Funzione, Smart Sensor Operator | 
| PoolFailures | pool.open\_slots. {pool\_name} | Conteggio | Piscina, {pool\_name} | 
| PoolStarvingTasks | pool.starving\_tasks. {pool\_name} | Conteggio | Piscina, {pool\_name} | 
| PoolOpenSlots | pool.open\_slots. {pool\_name} | Conteggio | Piscina, {pool\_name} | 
| PoolQueuedSlots | pool.queued\_slots. {nome\_pool} | Conteggio | Piscina, {pool\_name} | 
| PoolRunningSlots | pool.running\_slots. {pool\_name} | Conteggio | Piscina, {pool\_name} | 
| ProcessorTimeouts | dag\_processing.processor\_timeouts | Conteggio | Funzione, elaborazione DAG | 
| QueuedTasks | executor.queued\_tasks | Conteggio | Funzione, esecutore | 
| RunningTasks | executor.running\_tasks | Conteggio | Funzione, Executor | 
| TasksExecutable | scheduler.tasks.executable | Conteggio | Funzione, Scheduler | 
| TasksPending Non si applica ad Apache Airflow v2.2 e versioni successive.  | scheduler.tasks.pending | Conteggio | Funzione, Scheduler | 
| TasksRunning | scheduler.tasks.running | Conteggio | Funzione, Scheduler | 
| TasksStarving | scheduler.tasks.starving | Conteggio | Funzione, Scheduler | 
| TasksWithoutDagRun | scheduler.tasks.without\_dagrun | Conteggio | Funzione, Scheduler | 
| DAGFileProcessingLastNumOfDbQueries Disponibile in Apache Airflow v2.10.1 e versioni successive.  | dag\_processing.last\_num\_of\_db\_queries. {nome\_file} | Conteggio | Nome file DAG, {dag\_filename} | 
| PoolScheduledSlots Disponibile in Apache Airflow v2.10.1 e versioni successive.  | pool.scheduled\_slots. {pool\_name} | Conteggio | Piscina, {pool\_name} | 
| TaskCpuUsage Disponibile in Apache Airflow v2.10.1 e versioni successive.  | utilizzo della CPU. {id\_giorno}. {id\_attività} | Percentuale | DAG, {dag\_id}<br />Attività, {task\_id} | 
| TaskMemoryUsage Disponibile in Apache Airflow v2.10.1 e versioni successive.  | mem.usage. {id\_giorno}. {id\_attività} | Percentuale | DAG, {dag\_id}<br />Attività, {task\_id} | 

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

[https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#timers](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#timers)


| CloudWatch parametro | Metrica Apache Airflow | Unità | Dimensione | 
| --- | --- | --- | --- | 
| Raccogli DBDags | collect\_db\_dags | Millisecondi | Funzione, elaborazione DAG | 
| CriticalSectionDuration | scheduler.critical\_section\_duration | Millisecondi | Funzione, Scheduler | 
| CriticalSectionQueryDuration Disponibile per Apache Airflow v2.5.1 e versioni successive.  | scheduler.critical\_section\_query\_duration | Millisecondi | Funzione, Scheduler | 
| DAGDependencyControlla | dagrun.dependency-check. {id\_giorno} | Millisecondi | DAG, {dag\_id} | 
| DAGDurationFallito | dagrun.duration.failed. {id\_giorno} | Millisecondi | DAG, {dag\_id} | 
| DAGDurationSuccesso | dagrun.duration.success. {id\_giorno} | Millisecondi | DAG, {dag\_id} | 
| DAGFileProcessingLastDuration | dag\_processing.last\_duration. {nome\_file} | Secondi | Nome file DAG, {dag\_filename} | 
| DAGScheduleRitardo | dagrun.schedule\_delay. {id\_giorno} | Millisecondi | DAG, {dag\_id} | 
| FirstTaskSchedulingDelay | dagrun. {dag\_id} .first\_task\_scheduling\_delay | Millisecondi | Giorno, {dat\_id} | 
| SchedulerLoopDuration Disponibile per Apache Airflow v2.5.1 e versioni successive.  | scheduler.scheduler\_loop\_duration | Millisecondi | Funzione, Scheduler | 
| TaskInstanceDuration | giorno. {id\_giorno}. {task\_id} .durata | Millisecondi | DAG, {dat\_id}<br />Attività, {task\_id} | 
| TaskInstanceQueuedDuration | giorno. `{dag_id}`. `{task_id}`.durata\_in coda Disponibile per Apache Airflow v2.7.2 e versioni successive.  | Millisecondi | DAG, {dag\_id}<br />Attività, {task\_id} | 
| TaskInstanceScheduledDuration Disponibile per Apache Airflow v2.7.2 e versioni successive.  | giorno. `{dag_id}`. `{task_id}`.durata\_pianificata | Millisecondi | GIORNO, {dag\_id}<br />Attività, {task\_id} | 

## Scelta delle metriche da segnalare
<a name="choosing-metrics"></a>

[Puoi scegliere quali metriche di Apache Airflow vengono emesse CloudWatch o bloccate da Apache Airflow, utilizzando le seguenti opzioni di configurazione di Amazon MWAA:](configuring-env-variables.md)
+ **`metrics.metrics_allow_list`**— Un elenco di prefissi separati da virgole che puoi utilizzare per selezionare a quali metriche vengono emesse dal tuo ambiente. CloudWatch Utilizzate questa opzione se desiderate che Apache Airflow non invii tutte le metriche disponibili e selezioni invece un sottoinsieme di elementi. Ad esempio, `scheduler,executor,dagrun`.
+ **`metrics.metrics_block_list`**— Un elenco di prefissi separati da virgole per filtrare le metriche che iniziano con gli elementi dell'elenco. Ad esempio, `scheduler,executor,dagrun`.

Se si configurano entrambi `metrics.metrics_allow_list` e`metrics.metrics_block_list`, Apache Airflow ignora. `metrics.metrics_block_list` Se configuri `metrics.metrics_block_list` ma non lo fai`metrics.metrics_allow_list`, Apache Airflow filtra gli elementi specificati in. `metrics.metrics_block_list`

**Nota**  
Le opzioni di `metrics.metrics_block_list` configurazione `metrics.metrics_allow_list` e si applicano solo ad Apache Airflow v2.6.3 e versioni successive. Per la versione precedente di Apache Airflow `metrics.statsd_allow_list` usa e invece. `metrics.statsd_block_list`

## Fasi successive
<a name="mwaa-metrics202-next-up"></a>
+ Esplora il funzionamento dell'API Amazon MWAA utilizzato per pubblicare i parametri di salute dell'ambiente su. [PublishMetrics](https://docs.aws.amazon.com/mwaa/latest/API/API_PublishMetrics.html)