

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
<a name="access-metrics-cw"></a>

Apache Airflow v2 dan v3 sudah disiapkan untuk mengumpulkan dan mengirim [ metrik ](https://github.com/etsy/statsd) StatSD untuk lingkungan Alur Kerja Terkelola Amazon untuk Apache Airflow ke Amazon. CloudWatch Daftar lengkap metrik yang dikirimkan Apache Airflow tersedia di [ halaman ](https://airflow.apache.org/docs/apache-airflow/stable/administration-and-deployment/logging-monitoring/metrics.html) Metrik di panduan referensi * Apache Airflow*. Halaman ini menjelaskan metrik Apache Airflow yang tersedia di CloudWatch dan cara mengakses metrik di CloudWatch konsol.

**Contents**
+ [Istilah](#access-metrics-cw-terms)
+ [Dimensi](#metrics-dimensions)
+ [Mengakses metrik di CloudWatch konsol](#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 yang dilaporkan](#choosing-metrics)
+ [Apa selanjutnya?](#mwaa-metrics202-next-up)

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

**Namespace**  
Namespace adalah wadah untuk CloudWatch metrik AWS layanan. 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**  
Met [ rik ](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**  
Statistik memiliki satuan ukuran. Untuk Amazon MWAA, unit termasuk * Hitungan*, Detik*, * dan * Milidetik. * Untuk Amazon MWAA, unit ditetapkan berdasarkan unit dalam metrik Aliran Udara asli.

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

Bagian ini menjelaskan * pengelompokan CloudWatch * Dimensi untuk metrik Apache Airflow di CloudWatch.


| Dimensi | Deskripsi | 
| --- | --- | 
| HARI | Menunjukkan nama DAG Apache Airflow tertentu. | 
| Nama file DAG | Menunjukkan nama file DAG Apache Airflow 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 Renang | Menunjukkan kumpulan pekerja Apache Airflow tertentu. | 
| Tugas | Menunjukkan tugas Apache Airflow tertentu. | 
| HostName | Menunjukkan nama host untuk proses Apache Airflow tertentu yang sedang berjalan. | 

## Mengakses metrik di CloudWatch konsol
<a name="access-metrics-cw-console"></a>

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 milik 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 kinerja untuk metrik Apache Airflow, seperti * DAG, Environment, Task*.

## Metrik Apache Airflow tersedia di CloudWatch
<a name="available-metrics-cw"></a>

Bagian ini menjelaskan metrik dan dimensi Apache Airflow yang dikirim ke CloudWatch.

### Penghitung Aliran Udara Apache
<a name="counters-metrics"></a>

Metrik Apache Airflow di bagian ini berisi data tentang Pengh *itung Aliran Udara [Apache](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 | 
| GagalSlacallback Hanya tersedia untuk Apache Airflow v2.4.3 hingga v2.10.3.  | sla\_callback\_notifikasi\_kegagalan | Hitungan | Fungsi, Penjadwal | 
| Pembaruan Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru.  | Pembaruan kumpulan data | 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.  | selery.execute\_command.kegagalan | Hitungan | Fungsi, Seledri | 
| FilePathQueueUpdateCount Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru.  | dag\_memproses.file\_path\_queue\_update\_count | Hitungan | Fungsi, Penjadwal | 
| CriticalSectionBusy | Scheduler.critical\_section\_busy | Hitungan | Fungsi, Penjadwal | 
| DagBagSize | ukuran dagbag\_ | Hitungan | Fungsi, Pengolahan DAG | 
| DagCallbackExceptions | dag.callback\_pengecualian | Hitungan | DAG, Semua | 
| FailedSLAEmailAttempts Tidak tersedia untuk Apache Airflow v3.0.6 dan yang lebih baru.  | sla\_email\_notifikasi\_kegagalan | Hitungan | Fungsi, Penjadwal | 
| TaskInstanceFinished | ti.selesai. {dag\_id}. {id\_tugas}. {negara bagian} | Hitungan | HARI, {dag\_id}<br />Tugas, {task\_id}<br />Negara bagian, {negara bagian} | 
| JobEnd | {nama\_pekerjaan} \_akhir | Hitungan | Pekerjaan, {job\_name} | 
| JobHeartbeatFailure | {nama\_pekerjaan} \_gagal\_detak jantung | Hitungan | Pekerjaan, {job\_name} | 
| JobStart | {nama\_pekerjaan} \_mulai | Hitungan | Pekerjaan, {job\_name} | 
| ManagerStalls | dag\_processing.manager\_stall | Hitungan | Fungsi, Pengolahan DAG | 
| OperatorFailures | operator\_failures\_ {nama\_operator} | Hitungan | Operator, {operator\_name} | 
| OperatorSuccesses | operator\_successes\_ {nama\_operator} | Hitungan | Operator, {operator\_name} | 
| OtherCallbackCount Tersedia di Apache Airflow v2.6.3 dan yang lebih baru.  | dag\_memproses.lain\_callback\_count | Hitungan | Fungsi, Penjadwal | 
| Proses | proses pengolahan dag\_hari | Hitungan | Fungsi, Pengolahan DAG | 
| SchedulerHeartbeat | penjadwal\_detak jantung | Hitungan | Fungsi, Penjadwal | 
| StartedTaskInstances | ti.mulai. {dag\_id}. {id\_tugas} | Hitungan | DAG, Semua<br />Tugas, Semua | 
| SlaCallbackCount | dag\_processing.sla\_callback\_count Tersedia untuk Apache Airflow v2.6.3 dan yang lebih baru.  | Hitungan | Fungsi, Penjadwal | 
| TasksKilledExternally | penjadwal.tasks.killed\_eksternal | Hitungan | Fungsi, Penjadwal | 
| TaskTimeoutError | celery.task\_timeout\_error | Hitungan | Fungsi, Seledri | 
| TaskInstanceCreatedUsingOperator | tugas\_instance\_diciptakan- {nama\_operator} | Hitungan | Operator, {operator\_name} | 
| TaskInstancePreviouslySucceeded | sebelumnya\_berhasil | Hitungan | DAG, Semua<br />Tugas, Semua | 
| TaskInstanceFailures | ti\_kegagalan | Hitungan | DAG, Semua<br />Tugas, Semua | 
| TaskInstanceSuccesses | ti\_sukses | Hitungan | DAG, Semua<br />Tugas, Semua | 
| TaskRemovedFromDAG | tugas\_menghapus\_dari\_hari. {dag\_id} | Hitungan | HARI, {dag\_id} | 
| TaskRestoredToDAG | tugas\_dipulihkan\_ke\_hari. {dag\_id} | Hitungan | HARI, {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\_uta\_utama | Hitungan | Fungsi, Pemicu | 
| TriggerHeartbeat Tersedia untuk Apache Airflow v2.8.1 dan yang lebih baru.  | triggerer\_detak jantung | Hitungan | Fungsi, Pemicu | 
| TaskInstanceCreatedUsingOperator | aliran air.tugas\_instance\_created\_ `{operator_name}` Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru.  | Hitungan | Operator, `{operator_name}` | 
| ZombiesKilled | zombies\_terbunuh | Hitungan | DAG, Semua<br />Tugas, Semua | 

### Pengukur Aliran Udara Apache
<a name="gauges-metrics"></a>

Metrik Apache Airflow di bagian ini berisi data tentang Pengukur Aliran Udara [ Apache*. *](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 | kesalahan dag\_file\_refresh | Hitungan | Fungsi, Pengolahan DAG | 
| ImportErrors | dag\_memproses.import\_error\_ | Hitungan | Fungsi, Pengolahan DAG | 
| ExceptionFailures | smart\_sensor\_operator.kegagalan luar biasa | Hitungan | Fungsi, Operator Sensor Cerdas | 
| ExecutedTasks | smart\_sensor\_operator.tugas yang dieksekusi | Hitungan | Fungsi, Operator Sensor Cerdas | 
| InfraFailures | smart\_sensor\_operator.infra\_failure | Hitungan | Fungsi, Operator Sensor Cerdas | 
| LoadedTasks | smart\_sensor\_operator.tugas-tugas yang dimuat | Hitungan | Fungsi, Operator Sensor Cerdas | 
| TotalParseTime | dag\_memproses.total\_parse\_waktu | Detik | Fungsi, Pengolahan DAG | 
| TriggeredDagRuns Tersedia di Apache Airflow v2.6.3 dan yang lebih baru.  | set data.triggered\_dagruns | Hitungan | Fungsi, Penjadwal | 
| TriggersRunning Tersedia di Apache Airflow v2.7.2 dan yang lebih baru.  | pemicu.berjalan. {{{hostname}}} | Hitungan | Fungsi, Pemicu<br />HostName, {{{hostname}}} | 
| PoolDeferredSlots Tersedia di Apache Airflow v2.7.2 dan yang lebih baru.  | pool.deferred\_slot. `{pool_name}` | Hitungan | Kolam, {pool\_name} | 
| DAGFileProcessingLastRunSecondsAgo | dag\_processing.last\_run.detik\_lalu. {dag\_nama file} | Detik | Nama file DAG, {dag\_filename} | 
| OpenSlots | pelakutan.open\_slots | Hitungan | Fungsi, Pelaksana | 
| OrphanedTasksAdopted | penjadwal.orfaned\_tasks.diadopsi | Hitungan | Fungsi, Penjadwal | 
| OrphanedTasksCleared | penjadwal.orfaned\_tasks.cleared | Hitungan | Fungsi, Penjadwal | 
| PokedExceptions | smart\_sensor\_operator.poked\_pengecualian | Hitungan | Fungsi, Operator Sensor Cerdas | 
| PokedSuccess | smart\_sensor\_operator.poked\_success | Hitungan | Fungsi, Operator Sensor Cerdas | 
| PokedTasks | smart\_sensor\_operator.poked\_tugas | Hitungan | Fungsi, Operator Sensor Cerdas | 
| PoolFailures | pool.open\_slots. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| PoolStarvingTasks | pool.tugas\_kelaparan. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| PoolOpenSlots | pool.open\_slots. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| PoolQueuedSlots | pool.queued\_slots. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| PoolRunningSlots | pool.running\_slots. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| ProcessorTimeouts | dag\_pengolahan.processor\_timeout | Hitungan | Fungsi, Pengolahan DAG | 
| QueuedTasks | executor.queued\_tasks | Hitungan | Fungsi, Pelaksana | 
| RunningTasks | eksekutor.running\_tugas | Hitungan | Fungsi, Pelaksana | 
| TasksExecutable | penjadwal.tugas.dapat dieksekusi | Hitungan | Fungsi, Penjadwal | 
| TasksPending Tidak berlaku untuk Apache Airflow v2.2 dan yang lebih baru.  | penjadwal.tasks.tertunda | Hitungan | Fungsi, Penjadwal | 
| TasksRunning | penjadwal.tugas.berjalan | Hitungan | Fungsi, Penjadwal | 
| TasksStarving | penjadwal.tasks.kelaparan | Hitungan | Fungsi, Penjadwal | 
| TasksWithoutDagRun | penjadwal.tasks.tanpa\_dagrun | Hitungan | Fungsi, Penjadwal | 
| DAGFileProcessingLastNumOfDbQueries Tersedia di Apache Airflow v2.10.1 dan yang lebih baru.  | dag\_memproses.nom\_terakhir\_db\_query. {dag\_nama file} | Hitungan | Nama file DAG, {dag\_filename} | 
| PoolScheduledSlots Tersedia di Apache Airflow v2.10.1 dan yang lebih baru.  | pool.scheduled\_slots. {nama\_kolam} | Hitungan | Kolam, {pool\_name} | 
| TaskCpuUsage Tersedia di Apache Airflow v2.10.1 dan yang lebih baru.  | cpu.penggunaan. {dag\_id}. {id\_tugas} | Persen | HARI, {dag\_id}<br />Tugas, {task\_id} | 
| TaskMemoryUsage Tersedia di Apache Airflow v2.10.1 dan yang lebih baru.  | mem.penggunaan. {dag\_id}. {id\_tugas} | Persen | HARI, {dag\_id}<br />Tugas, {task\_id} | 

### Pengatur Waktu Aliran Udara Apache
<a name="timers-metrics"></a>

Metrik Apache Airflow di bagian ini berisi data tentang [ Apache Airflow * 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\_days | Milidetik | Fungsi, Pengolahan 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 | 
| DAGDependencyCheck | dagrun.dependency-check. {dag\_id} | Milidetik | HARI, {dag\_id} | 
| DAGDurationFailed | dagrun.duration.gagal. {dag\_id} | Milidetik | HARI, {dag\_id} | 
| DAGDurationSuccess | dagrun.durasi.sukses. {dag\_id} | Milidetik | HARI, {dag\_id} | 
| DAGFileProcessingLastDuration | dag\_proses.durasi\_terakhir. {dag\_nama file} | Detik | Nama file DAG, {dag\_filename} | 
| DAGScheduleDelay | dagrun.schedule\_delay. {dag\_id} | Milidetik | HARI, {dag\_id} | 
| FirstTaskSchedulingDelay | dagrun. {dag\_id} .penundaan penjadwalan tugas pertama | Milidetik | HARI, {dag\_id} | 
| SchedulerLoopDuration Tersedia untuk Apache Airflow v2.5.1 dan yang lebih baru.  | penjadwal.scheduler\_loop\_durasi | Milidetik | Fungsi, Penjadwal | 
| TaskInstanceDuration | hari. {dag\_id}. {task\_id} .durasi | Milidetik | HARI, {dag\_id}<br />Tugas, {task\_id} | 
| TaskInstanceQueuedDuration | hari. `{dag_id}`. `{task_id}`.durasi\_antrian Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru.  | Milidetik | HARI, {dag\_id}<br />Tugas, {task\_id} | 
| TaskInstanceScheduledDuration Tersedia untuk Apache Airflow v2.7.2 dan yang lebih baru.  | hari. `{dag_id}`. `{task_id}`.durasi\_terjadwal | Milidetik | HARI, {dag\_id}<br />Tugas, {task\_id} | 

## Memilih metrik yang dilaporkan
<a name="choosing-metrics"></a>

Anda dapat memilih metrik Apache Airflow mana yang dipancarkan CloudWatch, atau diblokir oleh Apache Airflow, menggunakan opsi [Menggunakan opsi konfigurasi Apache Airflow di Amazon MWAA](configuring-env-variables.md) konfigurasi Amazon MWAA berikut:
+ **`metrics.metrics_allow_list`**— Daftar awalan yang dipisahkan koma yang dapat Anda gunakan untuk memilih metrik mana yang dipancarkan CloudWatch oleh lingkungan Anda. Gunakan opsi ini jika Anda ingin Apache Airflow tidak mengirim semua metrik yang tersedia dan sebagai gantinya memilih 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 mengkonfigurasi keduanya `metrics.metrics_allow_list` dan`metrics.metrics_block_list`, Apache Airflow mengabaikan`metrics.metrics_block_list`. Jika Anda mengkonfigurasi `metrics.metrics_block_list` tetapi tidak`metrics.metrics_allow_list`, Apache Airflow menyaring 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 gunakan `metrics.statsd_allow_list` dan sebagai `metrics.statsd_block_list` gantinya.

## Apa selanjutnya?
<a name="mwaa-metrics202-next-up"></a>
+ 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).