Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Metrik lingkungan Apache Airflow di CloudWatch
Apache Airflow v2 dan v3 sudah disiapkan untuk mengumpulkan dan mengirim metrik [StatSD](https://github.com/etsy/statsd) untuk Alur Kerja Terkelola Amazon untuk lingkungan Apache Airflow ke Amazon. CloudWatch [https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html) Halaman ini menjelaskan metrik Apache Airflow yang tersedia dan cara mengakses metrik CloudWatch di konsol. CloudWatch
**Contents**
+ [Ketentuan](#access-metrics-cw-terms)
+ [Dimensi](#metrics-dimensions)
+ [Mengakses metrik di konsol CloudWatch](#access-metrics-cw-console)
+ [Metrik Apache Airflow tersedia di CloudWatch](#available-metrics-cw)
+ [Penghitung Aliran Udara Apache](#counters-metrics)
+ [Pengukur Aliran Udara Apache](#gauges-metrics)
+ [Pengatur Waktu Aliran Udara Apache](#timers-metrics)
+ [Memilih metrik mana yang dilaporkan](#choosing-metrics)
+ [Apa selanjutnya?](#mwaa-metrics202-next-up)
## Ketentuan
**Namespace**
Namespace adalah wadah untuk CloudWatch metrik layanan. AWS *Untuk Amazon MWAA, namespace adalah AmazonMWAA.*
**CloudWatch metrik**
CloudWatch Metrik mewakili kumpulan titik data yang diurutkan waktu yang spesifik untuk CloudWatch.
**Metrik Aliran Udara Apache**
[Metrik](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html ) khusus untuk Apache Airflow.
**Dimensi**
Dimensi adalah name/value pasangan yang merupakan bagian dari identitas metrik.
**Unit**
Sebuah statistik memiliki satuan ukuran. *Untuk Amazon MWAA, unit termasuk *Hitung*, *Detik, dan Millidetik*.* Untuk Amazon MWAA, unit ditetapkan berdasarkan unit dalam metrik Aliran Udara asli.
## Dimensi
Bagian ini menjelaskan pengelompokan CloudWatch *Dimensi* untuk metrik Apache Airflow di. CloudWatch
| Dimensi | Deskripsi |
| --- | --- |
| HARI | Menunjukkan nama Apache Airflow DAG tertentu. |
| DAG Nama file | Menunjukkan nama file Apache Airflow DAG tertentu. |
| Fungsi | Dimensi ini digunakan untuk meningkatkan pengelompokan metrik di. CloudWatch |
| Pekerjaan | Menunjukkan pekerjaan Apache Airflow yang dijalankan oleh penjadwal. Selalu memiliki nilai`Job`. |
| Operator | Menunjukkan operator Apache Airflow tertentu. |
| Kolam | Menunjukkan kumpulan pekerja Apache Airflow tertentu. |
| Tugas | Menunjukkan tugas Apache Airflow tertentu. |
| HostName | Menunjukkan nama host untuk proses Apache Airflow tertentu yang berjalan. |
## Mengakses metrik di konsol CloudWatch
Bagian ini menjelaskan cara mengakses metrik kinerja CloudWatch untuk DAG tertentu.
**Untuk mengakses metrik kinerja untuk dimensi**
1. Buka [halaman Metrik](https://console.aws.amazon.com/cloudwatch/home#metricsV2:graph=~()) di CloudWatch konsol.
1. Pilih Anda Wilayah AWS.
1. Pilih namespace **AmazonMwaa**.
1. Di tab **Semua metrik**, pilih dimensi. Misalnya, *DAG, Lingkungan*.
1. Pilih CloudWatch metrik untuk dimensi. Misalnya, *TaskInstanceSuccesses* atau *TaskInstanceDuration*. Pilih **Grafik semua hasil pencarian**.
1. *Pilih tab **Graphed metrics** untuk mengakses statistik performa metrik Apache Airflow, seperti DAG, Environment, Task.*
## Metrik Apache Airflow tersedia di CloudWatch
Bagian ini menjelaskan metrik dan dimensi Apache Airflow yang dikirimkan ke. CloudWatch
### Penghitung Aliran Udara Apache
[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 metrik | Metrik Aliran Udara Apache | Unit | Dimensi |
| --- | --- | --- | --- |
| SLAMissed Hanya tersedia untuk Apache Airflow v2.4.3 hingga v2.10.3. | sla\_terlewatkan | Hitungan | Fungsi, Penjadwal |
| Gagal SLACallback Hanya tersedia untuk Apache Airflow v2.4.3 hingga v2.10.3. | sla\_callback\_notification\_failure | Hitungan | Fungsi, Penjadwal |
| Pembaruan Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru. | dataset.updates | Hitungan | Fungsi, Penjadwal |
| Yatim piatu Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru. | dataset.yatim piatu | Hitungan | Fungsi, Penjadwal |
| FailedCeleryTaskExecution Tersedia untuk Apache Airflow v2.4.3 dan yang lebih baru. | celery.execute\_command.failure | Hitungan | Fungsi, Seledri |
| FilePathQueueUpdateCount Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru. | dag\_processing.file\_path\_queue\_update\_count | Hitungan | Fungsi, Penjadwal |
| CriticalSectionBusy | scheduler.critical\_section\_busy | Hitungan | Fungsi, Penjadwal |
| DagBagSize | dagbag\_size | Hitungan | Fungsi, Pemrosesan DAG |
| DagCallbackExceptions | dag.callback\_exceptions | Hitungan | DAG, Semua |
| SLAEmailUpaya Gagal Tidak tersedia untuk Apache Airflow v3.0.6 dan yang lebih baru. | sla\_email\_notification\_failure | Hitungan | Fungsi, Penjadwal |
| TaskInstanceFinished | ti.finish. {dag\_id}. {task\_id}. {negara} | Hitungan | DAG, {dag\_id}
Tugas, {task\_id}
Negara, {state} |
| JobEnd | {job\_name} \_akhir | Hitungan | Job, {job\_name} |
| JobHeartbeatFailure | {job\_name} \_heartbeat\_failure | Hitungan | Job, {job\_name} |
| JobStart | {job\_name} \_mulai | Hitungan | Job, {job\_name} |
| ManagerStalls | dag\_processing.manager\_stalls | Hitungan | Fungsi, Pemrosesan DAG |
| OperatorFailures | operator\_failures\_ {operator\_name} | Hitungan | Operator, {operator\_name} |
| OperatorSuccesses | operator\_successes\_ {operator\_name} | Hitungan | Operator, {operator\_name} |
| OtherCallbackCount Tersedia dalam Apache Airflow v2.6.3 dan yang lebih baru. | dag\_processing.other\_callback\_count | Hitungan | Fungsi, Penjadwal |
| Proses | dag\_processing.processes | Hitungan | Fungsi, Pemrosesan DAG |
| SchedulerHeartbeat | scheduler\_heartbeat | Hitungan | Fungsi, Penjadwal |
| StartedTaskInstances | ti.start. {dag\_id}. {task\_id} | Hitungan | DAG, Semua
Tugas, Semua |
| SlaCallbackCount | dag\_processing.sla\_callback\_count Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru. | Hitungan | Fungsi, Penjadwal |
| TasksKilledExternally | scheduler.tasks.killed\_externally | Hitungan | Fungsi, Penjadwal |
| TaskTimeoutError | celery.task\_timeout\_error | Hitungan | Fungsi, Seledri |
| TaskInstanceCreatedUsingOperator | task\_instance\_created- {operator\_name} | Hitungan | Operator, {operator\_name} |
| TaskInstancePreviouslySucceeded | sebelumnya\_berhasil | Hitungan | DAG, Semua
Tugas, Semua |
| TaskInstanceFailures | ti\_failure | Hitungan | DAG, Semua
Tugas, Semua |
| TaskInstanceSuccesses | ti\_sukses | Hitungan | DAG, Semua
Tugas, Semua |
| TaskRemovedFromDAG | task\_removed\_from\_dag. {dag\_id} | Hitungan | DAG, {dag\_id} |
| TaskRestoredToDAG | task\_restored\_to\_dag. {dag\_id} | Hitungan | DAG, {dag\_id} |
| TriggersSucceeded Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | pemicu.berhasil | Hitungan | Fungsi, Pemicu |
| TriggersFailed Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | pemicu.gagal | Hitungan | Fungsi, Pemicu |
| TriggersBlockedMainThread Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | triggers.blocked\_main\_thread | Hitungan | Fungsi, Pemicu |
| TriggerHeartbeat Tersedia untuk Apache Airflow v2.8.1 dan yang lebih baru. | triggerer\_detak jantung | Hitungan | Fungsi, Pemicu |
| TaskInstanceCreatedUsingOperator | airflow.task\_instance\_created\_ `{operator_name}` Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | Hitungan | Operator, `{operator_name}` |
| ZombiesKilled | zombie\_dibunuh | Hitungan | DAG, Semua
Tugas, Semua |
### Pengukur Aliran Udara Apache
[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 metrik | Metrik Aliran Udara Apache | Unit | Dimensi |
| --- | --- | --- | --- |
| DAGFileRefreshError | dag\_file\_refresh\_error | Hitungan | Fungsi, Pemrosesan DAG |
| ImportErrors | dag\_processing.import\_errors | Hitungan | Fungsi, Pemrosesan DAG |
| ExceptionFailures | smart\_sensor\_operator.exception\_failure | Hitungan | Fungsi, Operator Sensor Cerdas |
| ExecutedTasks | smart\_sensor\_operator.executed\_tasks | Hitungan | Fungsi, Operator Sensor Cerdas |
| InfraFailures | smart\_sensor\_operator.infra\_failure | Hitungan | Fungsi, Operator Sensor Cerdas |
| LoadedTasks | smart\_sensor\_operator.loaded\_tasks | Hitungan | Fungsi, Operator Sensor Cerdas |
| TotalParseTime | dag\_processing.total\_parse\_time | Detik | Fungsi, Pemrosesan DAG |
| TriggeredDagRuns Tersedia dalam Apache Airflow v2.6.3 dan yang lebih baru. | dataset.triggered\_dagruns | Hitungan | Fungsi, Penjadwal |
| TriggersRunning Tersedia dalam Apache Airflow v2.7.2 dan yang lebih baru. | pemicu.running. {{{hostname}}} | Hitungan | Fungsi, Pemicu
HostName, {{{hostname}}} |
| PoolDeferredSlots Tersedia dalam Apache Airflow v2.7.2 dan yang lebih baru. | pool.deferred\_slots. `{pool_name}` | Hitungan | Kolam renang, {pool\_name} |
| DAGFileProcessingLastRunSecondsAgo | dag\_processing.last\_run.seconds\_ago. {dag\_nama file} | Detik | DAG Nama file, {dag\_filename} |
| OpenSlots | executor.open\_slots | Hitungan | Fungsi, Pelaksana |
| OrphanedTasksAdopted | scheduler.orphaned\_tasks.adopted | Hitungan | Fungsi, Penjadwal |
| OrphanedTasksCleared | scheduler.orphaned\_tasks.cleared | Hitungan | Fungsi, Penjadwal |
| PokedExceptions | smart\_sensor\_operator.poked\_exception | Hitungan | Fungsi, Operator Sensor Cerdas |
| PokedSuccess | smart\_sensor\_operator.poked\_success | Hitungan | Fungsi, Operator Sensor Cerdas |
| PokedTasks | smart\_sensor\_operator.poked\_tasks | Hitungan | Fungsi, Operator Sensor Cerdas |
| PoolFailures | pool.open\_slots. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| PoolStarvingTasks | pool.starving\_tasks. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| PoolOpenSlots | pool.open\_slots. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| PoolQueuedSlots | pool.queued\_slots. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| PoolRunningSlots | pool.running\_slots. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| ProcessorTimeouts | dag\_processing.processor\_timeouts | Hitungan | Fungsi, Pemrosesan DAG |
| QueuedTasks | executor.queued\_tasks | Hitungan | Fungsi, Pelaksana |
| RunningTasks | executor.running\_tasks | Hitungan | Fungsi, Pelaksana |
| TasksExecutable | scheduler.tasks.executable | Hitungan | Fungsi, Penjadwal |
| TasksPending Tidak berlaku untuk Apache Airflow v2.2 dan yang lebih baru. | scheduler.tasks.pending | Hitungan | Fungsi, Penjadwal |
| TasksRunning | scheduler.tasks.running | Hitungan | Fungsi, Penjadwal |
| TasksStarving | scheduler.tasks.starving | Hitungan | Fungsi, Penjadwal |
| TasksWithoutDagRun | scheduler.tasks.without\_dagrun | Hitungan | Fungsi, Penjadwal |
| DAGFileProcessingLastNumOfDbQueries Tersedia dalam Apache Airflow v2.10.1 dan yang lebih baru. | dag\_processing.last\_num\_of\_db\_queries. {dag\_nama file} | Hitungan | DAG Nama file, {dag\_filename} |
| PoolScheduledSlots Tersedia dalam Apache Airflow v2.10.1 dan yang lebih baru. | pool.scheduled\_slots. {pool\_name} | Hitungan | Kolam renang, {pool\_name} |
| TaskCpuUsage Tersedia dalam Apache Airflow v2.10.1 dan yang lebih baru. | cpu.usage. {dag\_id}. {task\_id} | Persen | DAG, {dag\_id}
Tugas, {task\_id} |
| TaskMemoryUsage Tersedia dalam Apache Airflow v2.10.1 dan yang lebih baru. | mem.penggunaan. {dag\_id}. {task\_id} | Persen | DAG, {dag\_id}
Tugas, {task\_id} |
### Pengatur Waktu Aliran Udara Apache
[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 metrik | Metrik Aliran Udara Apache | Unit | Dimensi |
| --- | --- | --- | --- |
| Kumpulkan DBDags | collect\_db\_dags | Milidetik | Fungsi, Pemrosesan DAG |
| CriticalSectionDuration | scheduler.critical\_section\_duration | Milidetik | Fungsi, Penjadwal |
| CriticalSectionQueryDuration Tersedia untuk Apache Airflow v2.5.1 dan yang lebih baru. | scheduler.critical\_section\_query\_duration | Milidetik | Fungsi, Penjadwal |
| DAGDependencyMemeriksa | dagrun.dependency-check. {dag\_id} | Milidetik | DAG, {dag\_id} |
| DAGDurationGagal | dagrun.duration.failed. {dag\_id} | Milidetik | DAG, {dag\_id} |
| DAGDurationSukses | dagrun.duration.success. {dag\_id} | Milidetik | DAG, {dag\_id} |
| DAGFileProcessingLastDuration | dag\_processing.last\_duration. {dag\_nama file} | Detik | DAG Nama file, {dag\_filename} |
| DAGScheduleKeterlambatan | dagrun.schedule\_delay. {dag\_id} | Milidetik | DAG, {dag\_id} |
| FirstTaskSchedulingDelay | dagrun. {dag\_id} .first\_task\_scheduling\_delay | Milidetik | DAG, {dag\_id} |
| SchedulerLoopDuration Tersedia untuk Apache Airflow v2.5.1 dan yang lebih baru. | scheduler.scheduler\_loop\_duration | Milidetik | Fungsi, Penjadwal |
| TaskInstanceDuration | hari ini. {dag\_id}. {task\_id} .durasi | Milidetik | DAG, {dag\_id}
Tugas, {task\_id} |
| TaskInstanceQueuedDuration | hari ini. `{dag_id}`. `{task_id}`.antrian\_durasi Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | Milidetik | DAG, {dag\_id}
Tugas, {task\_id} |
| TaskInstanceScheduledDuration Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru. | hari ini. `{dag_id}`. `{task_id}`.scheduled\_duration | Milidetik | DAG, {dag\_id}
Tugas, {task\_id} |
## Memilih metrik mana yang dilaporkan
[Anda dapat memilih metrik Apache Airflow mana yang dipancarkan, CloudWatch atau diblokir oleh Apache Airflow, menggunakan opsi konfigurasi Amazon MWAA berikut:](configuring-env-variables.md)
+ **`metrics.metrics_allow_list`**— Daftar awalan dipisahkan koma yang dapat Anda gunakan untuk memilih metrik mana yang dipancarkan oleh lingkungan Anda. CloudWatch Gunakan opsi ini jika Anda ingin Apache Airflow tidak mengirim semua metrik yang tersedia dan sebagai gantinya pilih subset elemen. Misalnya, `scheduler,executor,dagrun`.
+ **`metrics.metrics_block_list`**— Daftar awalan yang dipisahkan koma untuk menyaring metrik yang dimulai dengan elemen daftar. Misalnya, `scheduler,executor,dagrun`.
Jika Anda mengonfigurasi keduanya `metrics.metrics_allow_list` dan`metrics.metrics_block_list`, Apache Airflow mengabaikan. `metrics.metrics_block_list` Jika Anda mengonfigurasi `metrics.metrics_block_list` tetapi tidak`metrics.metrics_allow_list`, Apache Airflow memfilter elemen yang Anda tentukan. `metrics.metrics_block_list`
**catatan**
Opsi `metrics.metrics_allow_list` dan `metrics.metrics_block_list` konfigurasi hanya berlaku untuk Apache Airflow v2.6.3 dan yang lebih baru. Untuk versi sebelumnya dari Apache Airflow `metrics.statsd_allow_list` gunakan dan sebagai gantinya. `metrics.statsd_block_list`
## Apa selanjutnya?
+ Jelajahi operasi Amazon MWAA API yang digunakan untuk mempublikasikan metrik kesehatan lingkungan di. [PublishMetrics](https://docs.aws.amazon.com/mwaa/latest/API/API_PublishMetrics.html)