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.
# Apache Airflow Airflow-Umgebungsmetriken in CloudWatch
Apache Airflow v2 und v3 sind bereits so eingerichtet, dass sie [StatsD-Metriken](https://github.com/etsy/statsd) für eine Amazon Managed Workflows for Apache Airflow Airflow-Umgebung sammeln und an Amazon senden. CloudWatch Die vollständige Liste der von Apache Airflow gesendeten Metriken ist auf der Seite [Metriken](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html) im *Apache Airflow 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 CloudWatch Konsole zugreifen können.
**Contents**
+ [Bedingungen](#access-metrics-cw-terms)
+ [Dimensionen](#metrics-dimensions)
+ [Zugreifen auf Metriken in der Konsole CloudWatch](#access-metrics-cw-console)
+ [Apache Airflow-Metriken verfügbar in CloudWatch](#available-metrics-cw)
+ [Apache Airflow Luftstromzähler](#counters-metrics)
+ [Apache Airflow Luftstrommessgeräte](#gauges-metrics)
+ [Apache Airflow Timer](#timers-metrics)
+ [Auswahl der Metriken, die 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 nach der Zeit geordneten Satz von Datenpunkten dar, die spezifisch für sind. CloudWatch
**Apache Airflow-Metriken**
Die spezifischen [Metriken](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html ) für Apache Airflow.
**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 von CloudWatch *Dimensionen* für Apache Airflow-Metriken in beschrieben. CloudWatch
| Dimension | Description |
| --- | --- |
| DAG | 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 Airflow-Job an, der vom Scheduler ausgeführt wird. Hat immer einen Wert von. `Job` |
| Operator | Zeigt einen bestimmten Apache Airflow Airflow-Operator an. |
| Pool | Weist auf einen bestimmten Apache Airflow Airflow-Workerpool hin. |
| Aufgabe | Weist auf eine bestimmte Apache Airflow Airflow-Aufgabe hin. |
| HostName | Gibt den Hostnamen für einen bestimmten laufenden Apache Airflow 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 Leistungskennzahlen für eine Dimension zu**
1. Öffnen Sie die [Seite „Metriken“](https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~()) 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, Umgebung*.
1. Wählen Sie eine CloudWatch Metrik für eine Dimension aus. Zum Beispiel *TaskInstanceSuccesses* oder *TaskInstanceDuration*. Wählen Sie **Alle Suchergebnisse grafisch** darstellen aus.
1. Wählen Sie die Registerkarte **Graphed Metrics**, um auf Leistungsstatistiken für Apache Airflow-Metriken wie *DAG, Umgebung, Task* zuzugreifen.
## Apache Airflow-Metriken verfügbar in CloudWatch
In diesem Abschnitt werden die Apache Airflow-Metriken und -Dimensionen beschrieben, an die CloudWatch gesendet werden.
### Apache Airflow Luftstromzähler
*Die Apache Airflow-Metriken in diesem Abschnitt enthalten Daten über [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 |
| --- | --- | --- | --- |
| SLAMissed Nur für Apache Airflow v2.4.3 bis v2.10.3 verfügbar. | sla\_missed | Anzahl | Funktion, Scheduler |
| Fehlgeschlagen SLACallback Nur für Apache Airflow v2.4.3 bis v2.10.3 verfügbar. | 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.verwaist | 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 |
| Fehlgeschlagene SLAEmail Versuche Nicht verfügbar für Apache Airflow v3.0.6 und höher. | sla\_email\_notification\_failure | Anzahl | Funktion, Scheduler |
| TaskInstanceFinished | bis ich fertig bin. {tag\_id}. {Aufgaben-ID}. {Bundesstaat} | Anzahl | TAG, {tag\_id}
Aufgabe, {task\_id}
Bundesstaat, {Bundesstaat} |
| JobEnd | {Jobname} \_Ende | Anzahl | Job, {job\_name} |
| JobHeartbeatFailure | {Jobname} \_Heartbeat\_Failure | Anzahl | Job, {job\_name} |
| JobStart | {Jobname} \_Start | Anzahl | Job, {job\_name} |
| ManagerStalls | dag\_processing.manager\_stalls | Anzahl | Funktion, DAG-Verarbeitung |
| OperatorFailures | operator\_failures\_ {operator\_name} | Anzahl | Betreiber, {operator\_name} |
| OperatorSuccesses | operator\_successes\_ {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, Alle |
| 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- {Operatorname} | Anzahl | Betreiber, {operator\_name} |
| TaskInstancePreviouslySucceeded | vorherig\_erfolgreich | Anzahl | DAG, Alle
Aufgabe, Alle |
| TaskInstanceFailures | ti\_failures | Anzahl | DAG, Alle
Aufgabe, Alle |
| TaskInstanceSuccesses | ti\_successes | Anzahl | DAG, Alle
Aufgabe, Alle |
| TaskRemovedFromTAG | task\_from\_dag entfernt. {tag\_id} | Anzahl | TAG, {dag\_id} |
| TaskRestoredToTAG | task\_restored\_to\_dag. {tag\_id} | Anzahl | TAG, {dag\_id} |
| TriggersSucceeded Verfügbar für Apache Airflow v2.7.2 und höher. | triggers.erfolgreich | Anzahl | Funktion, Auslöser |
| TriggersFailed Verfügbar für Apache Airflow v2.7.2 und höher. | triggers.failed | Anzahl | Funktion, Auslöser |
| TriggersBlockedMainThread Verfügbar für Apache Airflow v2.7.2 und höher. | triggers.blocked\_main\_thread | Anzahl | Funktion, Auslöser |
| TriggerHeartbeat Verfügbar für Apache Airflow v2.8.1 und höher. | triggerer\_heartbeat | Anzahl | Funktion, Triggerer |
| TaskInstanceCreatedUsingOperator | airflow.task\_instance\_created\_ `{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, Alle |
### Apache Airflow Luftstrommessgeräte
*Die Apache Airflow-Metriken in diesem Abschnitt enthalten Daten über [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, Auslöser
HostName, {{{hostname}}} |
| PoolDeferredSlots Verfügbar in Apache Airflow v2.7.2 und höher. | pool.deferred\_slots. `{pool_name}` | Anzahl | Schwimmbad, {Poolname} |
| DAGFileProcessingLastRunSecondsAgo | dag\_processing.last\_run.seconds\_ago. {dag\_Dateiname} | Sekunden | DAG-Dateiname, {dag\_filename} |
| OpenSlots | executor.open\_slots | Anzahl | Funktion, Executor |
| OrphanedTasksAdopted | scheduler.orphaned\_tasks.adoptiert | Anzahl | Funktion, Scheduler |
| OrphanedTasksCleared | scheduler.orphaned\_tasks.clear | Anzahl | Funktion, Scheduler |
| PokedExceptions | smart\_sensor\_operator.poked\_exception | Anzahl | Funktion, intelligenter Sensoroperator |
| PokedSuccess | smart\_sensor\_operator.poked\_success | Anzahl | Funktion, intelligenter Sensoroperator |
| PokedTasks | smart\_sensor\_operator.poked\_tasks | Anzahl | Funktion, intelligenter Sensoroperator |
| PoolFailures | pool.open\_slots. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| PoolStarvingTasks | pool.starving\_tasks. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| PoolOpenSlots | pool.open\_slots. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| PoolQueuedSlots | pool.queued\_slots. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| PoolRunningSlots | pool.running\_slots. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| 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\_dateiname} | Anzahl | DAG-Dateiname, {dag\_filename} |
| PoolScheduledSlots Verfügbar in Apache Airflow v2.10.1 und höher. | pool.scheduled\_slots. {Poolname} | Anzahl | Schwimmbad, {Poolname} |
| 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 |
| --- | --- | --- | --- |
| Sammeln DBDags | collect\_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 |
| DAGDependencyPrüfen | dagrun. Abhängigkeitsprüfung. {tag\_id} | Millisekunden | TAG, {dag\_id} |
| DAGDurationFehlgeschlagen | dagrun.duration.ist fehlgeschlagen. {dag\_id} | Millisekunden | TAG, {dag\_id} |
| DAGDurationErfolg | Tag. Dauer. Erfolg. {tag\_id} | Millisekunden | TAG, {dag\_id} |
| DAGFileProcessingLastDuration | dag\_processing.last\_duration. {dag\_Dateiname} | Sekunden | DAG-Dateiname, {dag\_filename} |
| DAGScheduleVerzögerung | dagrun.schedule\_delay. {tag\_id} | Millisekunden | TAG, {dag\_id} |
| FirstTaskSchedulingDelay | Dagrun. {tag\_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 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} |
## Auswahl der Metriken, die 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 von kommagetrennten Präfixen, anhand derer Sie auswählen können, an welche Metriken von Ihrer Umgebung ausgegeben werden. 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 kommagetrennten Präfixen, um Metriken herauszufiltern, die mit den Elementen der Liste beginnen. Beispiel, `scheduler,executor,dagrun`.
Wenn Sie `metrics.metrics_allow_list` sowohl als auch konfigurieren`metrics.metrics_block_list`, ignoriert `metrics.metrics_block_list` Apache Airflow. Wenn Sie konfigurieren, `metrics.metrics_block_list` aber nicht`metrics.metrics_allow_list`, filtert Apache Airflow die Elemente heraus, in `metrics.metrics_block_list` denen Sie angeben.
**Anmerkung**
Die `metrics.metrics_allow_list` und `metrics.metrics_block_list` Konfigurationsoptionen gelten nur für Apache Airflow v2.6.3 und höher. Verwenden Sie für frühere Versionen von Apache Airflow `metrics.statsd_block_list` stattdessen `metrics.statsd_allow_list` und.
## Als nächstes
+ Erkunden Sie den Amazon MWAA-API-Betrieb, der zur Veröffentlichung von Umweltgesundheitsmetriken verwendet wird, unter. [PublishMetrics](https://docs.aws.amazon.com/mwaa/latest/API/API_PublishMetrics.html)