Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
# Metriken zur Apache Airflow-Umgebung in CloudWatch
Apache Airflow v2 und v3 sind bereits so eingerichtet, dass sie [https://github.com/etsy/statsd](https://github.com/etsy/statsd) StatsD-Metriken für eine Amazon Managed Workflows for Apache Airflow-Umgebung sammeln und an Amazon senden. CloudWatch Die vollständige Liste der Metriken, die Apache Airflow sendet, ist auf der [ Seite „](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html)Metriken“ im * Apache Airflow-Referenzhandbuch verfügbar. * Auf dieser Seite werden die Apache Airflow-Metriken beschrieben, die in der Konsole verfügbar sind, CloudWatch und wie Sie auf Metriken in der Konsole zugreifen können. CloudWatch
**Contents**
+ [Bedingungen](#access-metrics-cw-terms)
+ [Dimensionen](#metrics-dimensions)
+ [Zugreifen auf Metriken in der Konsole CloudWatch](#access-metrics-cw-console)
+ [Apache Airflow-Metriken sind verfügbar in CloudWatch](#available-metrics-cw)
+ [Apache Airflow-Zähler](#counters-metrics)
+ [Apache Luftstrommessgeräte](#gauges-metrics)
+ [Apache Airflow-Timer](#timers-metrics)
+ [Wählen Sie aus, welche Metriken gemeldet werden](#choosing-metrics)
+ [Als nächstes](#mwaa-metrics202-next-up)
## Bedingungen
**Namespace**
Ein Namespace ist ein Container für die CloudWatch Metriken eines AWS Dienstes. Für Amazon MWAA lautet der Namespace AmazonMWAA. * *
**CloudWatch Metriken**
Eine CloudWatch Metrik stellt einen zeitlich geordneten Satz von Datenpunkten dar, die spezifisch für CloudWatch.
**Apache Airflow-Metriken**
Die für Apache Airflow [ spezifischen ](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html ) Metriken.
**Dimension**
Eine Dimension ist ein name/value Paar, das Teil der Identität einer Metrik ist.
**Einheit**
Eine Statistik hat eine Maßeinheit. Für Amazon MWAA umfassen die Einheiten * Anzahl*, * Sekunden * und Millisekunden. * * Für Amazon MWAA werden die Einheiten auf der Grundlage der Einheiten in den ursprünglichen Airflow-Metriken festgelegt.
## Dimensionen
In diesem Abschnitt wird die * Gruppierung der CloudWatch * Dimensionen für Apache Airflow-Metriken in beschrieben. CloudWatch
| Dimension | Description |
| --- | --- |
| DRAG | Zeigt einen bestimmten Apache Airflow DAG-Namen an. |
| DAG-Dateiname | Zeigt einen bestimmten Apache Airflow DAG-Dateinamen an. |
| Funktion | Diese Dimension wird verwendet, um die Gruppierung von Metriken in zu verbessern. CloudWatch |
| Aufgabe | Zeigt einen Apache Airflow-Job an, der vom Scheduler ausgeführt wird. Hat immer den Wert. `Job` |
| Operator | Zeigt einen bestimmten Apache Airflow-Operator an. |
| Pool | Zeigt einen bestimmten Apache Airflow-Worker-Pool an. |
| Aufgabe | Zeigt eine bestimmte Apache Airflow-Aufgabe an. |
| HostName | Gibt den Hostnamen für einen bestimmten laufenden Apache Airflow-Prozess an. |
## Zugreifen auf Metriken in der Konsole CloudWatch
In diesem Abschnitt wird beschrieben, wie Sie auf Leistungsmetriken CloudWatch für eine bestimmte DAG zugreifen.
**So greifen Sie auf Leistungsmetriken für eine Dimension zu**
1. Öffnen Sie die Seite „[https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~()](https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~())Metriken“ in der CloudWatch Konsole.
1. Wählen Sie Ihre AWS-Region.
1. Wählen Sie den ** AmazonMWAA-Namespace**.
1. Wählen Sie auf der ** Registerkarte ** Alle Metriken eine Dimension aus. Zum Beispiel * DAG, Environment*.
1. Wählen Sie eine CloudWatch Metrik für eine Dimension. Zum Beispiel *TaskInstanceSuccesses* oder *TaskInstanceDuration*. Wählen Sie Alle Suchergebnisse ** grafisch darstellen aus**.
1. Wählen Sie die ** Registerkarte „**Graphische Metriken“, um auf Leistungsstatistiken für Apache Airflow-Metriken wie * DAG, Environment, Task zuzugreifen. *
## Apache Airflow-Metriken sind verfügbar in CloudWatch
In diesem Abschnitt werden die Apache Airflow-Metriken und -Dimensionen beschrieben, an die gesendet wurden. CloudWatch
### Apache Airflow-Zähler
Die Apache Airflow-Metriken in diesem Abschnitt enthalten Daten zu [ Apache * Airflow Counters. *](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#counters)
| CloudWatch Metrik | Apache Airflow-Metrik | Einheit | Dimension |
| --- | --- | --- | --- |
| SLA verpasst Nur für Apache Airflow v2.4.3 bis v2.10.3 verfügbar. | sla\_verpasst | Anzahl | Funktion, Scheduler |
| SLA-Callback fehlgeschlagen Nur verfügbar für Apache Airflow v2.4.3 bis v2.10.3. | sla\_callback\_notification\_failure | Anzahl | Funktion, Scheduler |
| Aktualisierungen Verfügbar für Apache Airflow v2.6.3 und höher. | dataset.updates | Anzahl | Funktion, Scheduler |
| Verwaist Verfügbar für Apache Airflow v2.6.3 und höher. | dataset.orphaned | Anzahl | Funktion, Scheduler |
| FailedCeleryTaskExecution Verfügbar für Apache Airflow v2.4.3 und höher. | celery.execute\_command.failure | Anzahl | Funktion, Sellerie |
| FilePathQueueUpdateCount Verfügbar für Apache Airflow v2.6.3 und höher. | dag\_processing.file\_path\_queue\_update\_count | Anzahl | Funktion, Scheduler |
| CriticalSectionBusy | scheduler.critical\_section\_busy | Anzahl | Funktion, Scheduler |
| DagBagSize | dagbag\_size | Anzahl | Funktion, DAG-Verarbeitung |
| DagCallbackExceptions | dag.callback\_exceptions | Anzahl | DAG, Alle |
| FailedSLAEmailAttempts Nicht verfügbar für Apache Airflow v3.0.6 und höher. | sla\_email\_notification\_failure | Anzahl | Funktion, Scheduler |
| TaskInstanceFinished | fertig. {tag\_id}. {Aufgaben-ID}. {Bundesstaat} | Anzahl | DAG, {tag\_id}
Aufgabe, {task\_id}
Bundesland, {Bundesland} |
| JobEnd | {Jobname} \_ende | Anzahl | Beruf, {Jobname} |
| JobHeartbeatFailure | {Jobname} \_Herzschlagfehler | Anzahl | Beruf, {job\_name} |
| JobStart | {Jobname} \_starten | Anzahl | Beruf, {Jobname} |
| ManagerStalls | dag\_processing.manager\_stalls | Anzahl | Funktion, DAG-Verarbeitung |
| OperatorFailures | Operator\_Ausfälle\_ {Operator\_Name} | Anzahl | Betreiber, {operator\_name} |
| OperatorSuccesses | Operator\_erfolgreiches\_ {Operator\_Name} | Anzahl | Betreiber, {Operator\_Name} |
| OtherCallbackCount Verfügbar in Apache Airflow v2.6.3 und höher. | dag\_processing.other\_callback\_count | Anzahl | Funktion, Scheduler |
| Prozesse | dag\_processing.processes | Anzahl | Funktion, DAG-Verarbeitung |
| SchedulerHeartbeat | scheduler\_heartbeat | Anzahl | Funktion, Scheduler |
| StartedTaskInstances | ti.start. {tag\_id}. {Aufgaben-ID} | Anzahl | DAG, Alle
Aufgabe, Alles |
| SlaCallbackCount | dag\_processing.sla\_callback\_count Verfügbar für Apache Airflow v2.6.3 und höher. | Anzahl | Funktion, Scheduler |
| TasksKilledExternally | scheduler.tasks.killed\_external | Anzahl | Funktion, Scheduler |
| TaskTimeoutError | celery.task\_timeout\_error | Anzahl | Funktion, Sellerie |
| TaskInstanceCreatedUsingOperator | task\_instance\_created- {Operator\_Name} | Anzahl | Operator, {operator\_name} |
| TaskInstancePreviouslySucceeded | vorher\_erfolgreich | Anzahl | DAG, Alle
Aufgabe, Alles |
| TaskInstanceFailures | ti\_failures | Anzahl | DAG, Alle
Aufgabe, Alles |
| TaskInstanceSuccesses | ti\_successes | Anzahl | DAG, Alle
Aufgabe, Alles |
| TaskRemovedFromDAG | task\_from\_dag entfernt. {Tag\_ID} | Anzahl | TAG, {tag\_id} |
| TaskRestoredToDAG | Aufgabe\_zu\_Tag wiederhergestellt. {Tag\_ID} | Anzahl | TAG, {tag\_id} |
| TriggersSucceeded Verfügbar für Apache Airflow v2.7.2 und höher. | Triggers.erfolgreich | Anzahl | Funktion, Trigger |
| TriggersFailed Verfügbar für Apache Airflow v2.7.2 und höher. | Trigger. fehlgeschlagen | Anzahl | Funktion, Trigger |
| TriggersBlockedMainThread Verfügbar für Apache Airflow v2.7.2 und höher. | triggers.blocked\_main\_thread | Anzahl | Funktion, Trigger |
| TriggerHeartbeat Verfügbar für Apache Airflow v2.8.1 und höher. | triggerer\_heartbeat | Anzahl | Funktion, Triggerer |
| TaskInstanceCreatedUsingOperator | airflow.task\_instance\_erstellt\_ `{operator_name}` Verfügbar für Apache Airflow v2.7.2 und höher. | Anzahl | Betreiber, `{operator_name}` |
| ZombiesKilled | Zombies\_getötet | Anzahl | DAG, Alle
Aufgabe, Alles |
### Apache Luftstrommessgeräte
Die Apache Airflow-Metriken in diesem Abschnitt enthalten Daten zu [ Apache Airflow Gauges. * *](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#gauges)
| CloudWatch Metrik | Apache Airflow-Metrik | Einheit | Dimension |
| --- | --- | --- | --- |
| DAGFileRefreshError | dag\_file\_refresh\_error | Anzahl | Funktion, DAG-Verarbeitung |
| ImportErrors | dag\_processing.import\_errors | Anzahl | Funktion, DAG-Verarbeitung |
| ExceptionFailures | smart\_sensor\_operator.exception\_failures | Anzahl | Funktion, intelligenter Sensoroperator |
| ExecutedTasks | smart\_sensor\_operator.executed\_tasks | Anzahl | Funktion, intelligenter Sensoroperator |
| InfraFailures | smart\_sensor\_operator.infra\_failures | Anzahl | Funktion, intelligenter Sensoroperator |
| LoadedTasks | smart\_sensor\_operator.loaded\_tasks | Anzahl | Funktion, intelligenter Sensoroperator |
| TotalParseTime | dag\_processing.total\_parse\_time | Sekunden | Funktion, DAG-Verarbeitung |
| TriggeredDagRuns Verfügbar in Apache Airflow v2.6.3 und höher. | dataset.triggered\_dagruns | Anzahl | Funktion, Scheduler |
| TriggersRunning Verfügbar in Apache Airflow v2.7.2 und höher. | löst aus. Wird ausgeführt. {{{hostname}}} | Anzahl | Funktion, Trigger
HostName, {{{hostname}}} |
| PoolDeferredSlots Verfügbar in Apache Airflow v2.7.2 und höher. | pool.deferred\_slots. `{pool_name}` | Anzahl | Schwimmbad, {pool\_name} |
| DAGFileProcessingLastRunSecondsAgo | dag\_processing.last\_run.seconds\_ago. {dag\_filename} | Sekunden | DAG-Dateiname, {dag\_filename} |
| OpenSlots | executor.open\_slots | Anzahl | Funktion, Executor |
| OrphanedTasksAdopted | scheduler.orphaned\_tasks.adoptiert | Anzahl | Funktion, Scheduler |
| OrphanedTasksCleared | scheduler.orphaned\_tasks.cleared | Anzahl | Funktion, Scheduler |
| PokedExceptions | smart\_sensor\_operator.poked\_exception | Anzahl | Funktion, intelligenter Sensor-Operator |
| PokedSuccess | smart\_sensor\_operator.poked\_success | Anzahl | Funktion, intelligenter Sensoroperator |
| PokedTasks | smart\_sensor\_operator.poked\_tasks | Anzahl | Funktion, intelligenter Sensor-Operator |
| PoolFailures | pool.open\_slots. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| PoolStarvingTasks | pool.starving\_tasks. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| PoolOpenSlots | pool.open\_slots. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| PoolQueuedSlots | pool.queued\_slots. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| PoolRunningSlots | pool.running\_slots. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| ProcessorTimeouts | dag\_processing.processor\_timeouts | Anzahl | Funktion, DAG-Verarbeitung |
| QueuedTasks | executor.queued\_tasks | Anzahl | Funktion, Executor |
| RunningTasks | executor.running\_tasks | Anzahl | Funktion, Executor |
| TasksExecutable | scheduler.tasks.executable | Anzahl | Funktion, Scheduler |
| TasksPending Gilt nicht für Apache Airflow v2.2 und höher. | scheduler.tasks.pending | Anzahl | Funktion, Scheduler |
| TasksRunning | scheduler.tasks.running | Anzahl | Funktion, Scheduler |
| TasksStarving | scheduler.tasks.starving | Anzahl | Funktion, Scheduler |
| TasksWithoutDagRun | scheduler.tasks.without\_dagrun | Anzahl | Funktion, Scheduler |
| DAGFileProcessingLastNumOfDbQueries Verfügbar in Apache Airflow v2.10.1 und höher. | dag\_processing.last\_num\_of\_db\_queries. {dag\_filename} | Anzahl | DAG-Dateiname, {dag\_filename} |
| PoolScheduledSlots Verfügbar in Apache Airflow v2.10.1 und höher. | pool.scheduled\_slots. {Poolname} | Anzahl | Schwimmbad, {pool\_name} |
| TaskCpuUsage Verfügbar in Apache Airflow v2.10.1 und höher. | CPU-Nutzung. {tag\_id}. {Aufgaben-ID} | Prozent | TAG, {tag\_id}
Aufgabe, {task\_id} |
| TaskMemoryUsage Verfügbar in Apache Airflow v2.10.1 und höher. | mem.usage. {tag\_id}. {Aufgaben-ID} | Prozent | TAG, {tag\_id}
Aufgabe, {task\_id} |
### Apache Airflow-Timer
Die Apache Airflow-Metriken in diesem Abschnitt enthalten Daten über [ Apache Airflow Timer. * *](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html#timers)
| CloudWatch Metrik | Apache Airflow-Metrik | Einheit | Dimension |
| --- | --- | --- | --- |
| Sammle DBDAGs | sammle db\_dags | Millisekunden | Funktion, DAG-Verarbeitung |
| CriticalSectionDuration | scheduler.critical\_section\_duration | Millisekunden | Funktion, Scheduler |
| CriticalSectionQueryDuration Verfügbar für Apache Airflow v2.5.1 und höher. | scheduler.critical\_section\_query\_duration | Millisekunden | Funktion, Scheduler |
| DAGDependencyCheck | dagrun.dependency-check. {tag\_id} | Millisekunden | TAG, {tag\_id} |
| DAGDurationFailed | dagrun.duration.fehlgeschlagen. {tag\_id} | Millisekunden | TAG, {tag\_id} |
| DAGDurationSuccess | dagrun.duration.success. {tag\_id} | Millisekunden | TAG, {tag\_id} |
| DAGFileProcessingLastDuration | dag\_processing.last\_duration. {dag\_filename} | Sekunden | DAG-Dateiname, {dag\_filename} |
| DAGScheduleDelay | dagrun.schedule\_delay. {day\_id} | Millisekunden | TAG, {tag\_id} |
| FirstTaskSchedulingDelay | Dagrun. {dag\_id} .first\_task\_scheduling\_delay | Millisekunden | TAG, {dag\_id} |
| SchedulerLoopDuration Verfügbar für Apache Airflow v2.5.1 und höher. | scheduler.scheduler\_loop\_duration | Millisekunden | Funktion, Scheduler |
| TaskInstanceDuration | Tag. {tag\_id}. {task\_id} .dauer | Millisekunden | TAG, {Tag\_ID}
Aufgabe, {task\_id} |
| TaskInstanceQueuedDuration | Tag. `{dag_id}`. `{task_id}`. Dauer in der Warteschlange Verfügbar für Apache Airflow v2.7.2 und höher. | Millisekunden | DAG, {dag\_id}
Aufgabe, {task\_id} |
| TaskInstanceScheduledDuration Verfügbar für Apache Airflow v2.7.2 und höher. | Tag. `{dag_id}`. `{task_id}`. geplante Dauer | Millisekunden | TAG, {tag\_id}
Aufgabe, {task\_id} |
## Wählen Sie aus, welche Metriken gemeldet werden
Mithilfe der folgenden Amazon [ MWAA-Konfigurationsoptionen können Sie wählen CloudWatch, welche Apache Airflow-Metriken an Apache Airflow gesendet oder von Apache Airflow blockiert werden: ](configuring-env-variables.md)
+ **`metrics.metrics_allow_list`**— Eine Liste kommagetrennter Präfixe, anhand derer Sie auswählen können, an welche Metriken Ihre Umgebung sendet. CloudWatch Verwenden Sie diese Option, wenn Sie möchten, dass Apache Airflow nicht alle verfügbaren Metriken sendet und stattdessen eine Teilmenge von Elementen auswählt. Beispiel, `scheduler,executor,dagrun`.
+ **`metrics.metrics_block_list`**— Eine Liste von durch Kommas getrennten Präfixen zum Herausfiltern von Metriken, die mit den Elementen der Liste beginnen. Beispiel, `scheduler,executor,dagrun`.
Wenn Sie sowohl als auch `metrics.metrics_allow_list` konfigurieren, wird dies von Apache `metrics.metrics_block_list` Airflow ignoriert. `metrics.metrics_block_list` Wenn Sie konfigurieren, `metrics.metrics_block_list` aber nicht`metrics.metrics_allow_list`, filtert Apache Airflow die Elemente heraus, die Sie angeben. `metrics.metrics_block_list`
**Anmerkung**
Die `metrics.metrics_block_list` Konfigurationsoptionen `metrics.metrics_allow_list` und gelten nur für Apache Airflow v2.6.3 und höher. Verwenden Sie für frühere Versionen von Apache Airflow stattdessen und. `metrics.statsd_allow_list` `metrics.statsd_block_list`
## Als nächstes
+ Erfahren Sie mehr über den Amazon MWAA-API-Vorgang, der zur Veröffentlichung von Kennzahlen zum Zustand der Umgebung unter verwendet wird. [ PublishMetrics ](https://docs.aws.amazon.com/mwaa/latest/API/API_PublishMetrics.html)