Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Pantau Kinesis Data Streams
Anda dapat memantau aliran data di Amazon Kinesis Data Streams menggunakan fitur berikut:
+ [CloudWatch metrik](monitoring-with-cloudwatch.md) — Kinesis Data Streams mengirimkan metrik khusus CloudWatch Amazon dengan pemantauan terperinci untuk setiap aliran.
+ Agen [Kinesis — Agen](agent-health.md) Kinesis menerbitkan CloudWatch metrik khusus untuk membantu menilai apakah agen bekerja seperti yang diharapkan.
+ [Pencatatan API](logging-using-cloudtrail.md) — Kinesis Data AWS CloudTrail Streams digunakan untuk mencatat panggilan API dan menyimpan data dalam bucket Amazon S3.
+ Perpustakaan Klien [Kinesis — Perpustakaan Klien](monitoring-with-kcl.md) Kinesis (KCL) menyediakan metrik per shard, pekerja, dan aplikasi KCL.
+ [Perpustakaan Produser Kinesis — Amazon Kinesis Producer Library](monitoring-with-kpl.md) (KPL) menyediakan metrik per shard, pekerja, dan aplikasi KPL.
Untuk informasi selengkapnya tentang masalah pemantauan umum, pertanyaan, dan pemecahan masalah, lihat berikut ini:
+ [Metrik mana yang harus saya gunakan untuk memantau dan memecahkan masalah Kinesis Data Streams?](https://aws.amazon.com/premiumsupport/knowledge-center/kinesis-data-streams-troubleshoot/)
+ [Mengapa IteratorAgeMilliseconds nilai dalam Kinesis Data Streams terus meningkat?](https://aws.amazon.com/premiumsupport/knowledge-center/kinesis-data-streams-iteratorage-metric/)
# Pantau layanan Amazon Kinesis Data Streams dengan Amazon CloudWatch
Amazon Kinesis Data Streams CloudWatch dan Amazon terintegrasi sehingga Anda dapat mengumpulkan, melihat CloudWatch, dan menganalisis metrik untuk aliran data Kinesis Anda. Misalnya, untuk melacak penggunaan shard, Anda dapat memantau `IncomingBytes` dan `OutgoingBytes` metrik dan membandingkannya dengan jumlah pecahan dalam aliran.
Metrik streaming dan metrik tingkat shard yang Anda konfigurasikan secara otomatis dikumpulkan dan didorong ke setiap menit. CloudWatch Metrik diarsipkan selama dua minggu; setelah periode itu, data akan dibuang.
Tabel berikut menjelaskan tingkat aliran dasar dan pemantauan tingkat shard yang ditingkatkan untuk aliran data Kinesis.
| Tipe | Deskripsi |
| --- | --- |
| Dasar (tingkat aliran) | Data tingkat aliran dikirim secara otomatis setiap menit tanpa biaya. |
| Ditingkatkan (shard-level) | Data tingkat Shard dikirim setiap menit dengan biaya tambahan. Untuk mendapatkan tingkat data ini, Anda harus mengaktifkannya secara khusus untuk streaming menggunakan [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html)operasi. Untuk informasi tentang harga, lihat [halaman CloudWatch produk Amazon](https://aws.amazon.com/cloudwatch). |
## Dimensi dan metrik Amazon Kinesis Data Streams
Kinesis Data Streams mengirimkan CloudWatch metrik ke dua tingkat: tingkat aliran dan, secara opsional, tingkat pecahan. Metrik tingkat aliran adalah untuk kasus penggunaan pemantauan yang paling umum dalam kondisi normal. Metrik tingkat Shard adalah untuk tugas pemantauan tertentu, biasanya terkait dengan pemecahan masalah, dan diaktifkan menggunakan operasi. [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html)
Untuk penjelasan tentang statistik yang dikumpulkan dari CloudWatch metrik, lihat [CloudWatch Statistik](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#Statistic) di *Panduan CloudWatch Pengguna Amazon*.
**Topics**
+ [Metrik tingkat aliran dasar](#kinesis-metrics-stream)
+ [Metrik tingkat shard yang disempurnakan](#kinesis-metrics-shard)
+ [Dimensi untuk metrik Amazon Kinesis Data Streams](#kinesis-metricdimensions)
+ [Metrik Aliran Data Kinesis Amazon yang Direkomendasikan](#kinesis-metric-use)
### Metrik tingkat aliran dasar
`AWS/Kinesis`Namespace menyertakan metrik tingkat aliran berikut.
Kinesis Data Streams mengirimkan metrik tingkat aliran CloudWatch ini ke setiap menit. Metrik ini selalu tersedia.
| Metrik | Deskripsi |
| --- | --- |
| GetRecords.Bytes | Jumlah byte yang diambil dari aliran Kinesis, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili byte dalam satu `GetRecords` operasi untuk aliran dalam periode waktu yang ditentukan. Nama metrik tingkat shard: `OutgoingBytes` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| GetRecords.IteratorAge | Metrik ini tidak lagi digunakan. Gunakan `GetRecords.IteratorAgeMilliseconds`. |
| GetRecords.IteratorAgeMilliseconds | Usia catatan terakhir dalam semua `GetRecords` panggilan yang dilakukan terhadap aliran Kinesis, diukur selama periode waktu yang ditentukan. Usia adalah perbedaan antara waktu saat ini dan kapan catatan terakhir `GetRecords` panggilan ditulis ke aliran. Statistik Minimum dan Maksimum dapat digunakan untuk melacak kemajuan aplikasi konsumen Kinesis. Nilai nol menunjukkan bahwa catatan yang dibaca benar-benar terjebak dengan aliran. Nama metrik tingkat shard: `IteratorAgeMilliseconds` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Sampel Unit: Milidetik |
| GetRecords.Latency | Waktu yang dibutuhkan per operasi `GetRecords`, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata Unit: Milidetik |
| GetRecords.Records | Jumlah catatan yang diambil dari pecahan, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili catatan dalam satu `GetRecords` operasi untuk aliran dalam periode waktu yang ditentukan. Nama metrik tingkat shard: `OutgoingRecords` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| GetRecords.Success | Jumlah `GetRecords` operasi yang berhasil per aliran, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Rata-rata, Jumlah, Sampel Unit: Hitungan |
| IncomingBytes | Jumlah byte berhasil dimasukkan ke aliran Kinesis selama periode waktu yang ditentukan. Metrik ini mencakup byte dari `PutRecord` dan `PutRecords` operasi. Statistik Minimum, Maksimum, dan Rata-rata mewakili byte dalam operasi put tunggal untuk aliran dalam periode waktu yang ditentukan. Nama metrik tingkat shard: `IncomingBytes` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| IncomingRecords | Jumlah catatan yang berhasil dimasukkan ke aliran Kinesis selama periode waktu yang ditentukan. Metrik ini mencakup jumlah rekor dari `PutRecord` dan `PutRecords` operasi. Statistik Minimum, Maksimum, dan Rata-rata mewakili catatan dalam satu operasi put untuk aliran dalam periode waktu yang ditentukan. Nama metrik tingkat shard: `IncomingRecords` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecord.Bytes | Jumlah byte yang dimasukkan ke aliran Kinesis menggunakan operasi selama `PutRecord` periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| PutRecord.Latency | Waktu yang dibutuhkan per operasi `PutRecord`, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata Unit: Milidetik |
| PutRecord.Success | Jumlah `PutRecord` operasi yang berhasil per aliran Kinesis, diukur selama periode waktu yang ditentukan. Rata-rata mencerminkan persentase penulisan yang berhasil ke aliran. Dimensi: StreamName Statistik: Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.Bytes | Jumlah byte yang dimasukkan ke aliran Kinesis menggunakan operasi selama `PutRecords` periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| PutRecords.Latency | Waktu yang dibutuhkan per operasi `PutRecords`, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata Unit: Milidetik |
| PutRecords.Records | Metrik ini sudah usang. Gunakan `PutRecords.SuccessfulRecords`. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.Success | Jumlah `PutRecords` operasi di mana setidaknya satu catatan berhasil, per aliran Kinesis, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.TotalRecords | Jumlah total catatan yang dikirim dalam `PutRecords` operasi per aliran data Kinesis, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.SuccessfulRecords | Jumlah catatan yang berhasil dalam `PutRecords` operasi per aliran data Kinesis, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.FailedRecords | Jumlah catatan yang ditolak karena kegagalan internal dalam `PutRecords` operasi per aliran data Kinesis, diukur selama periode waktu yang ditentukan. Kegagalan internal sesekali diharapkan dan harus dicoba lagi. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| PutRecords.ThrottledRecords | Jumlah catatan yang ditolak karena pelambatan dalam `PutRecords` operasi per aliran data Kinesis, diukur selama periode waktu yang ditentukan. Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| ReadProvisionedThroughputExceeded | Jumlah `GetRecords` panggilan dibatasi untuk aliran selama periode waktu yang ditentukan. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. Ketika statistik Minimum memiliki nilai 1, semua catatan dibatasi untuk aliran selama periode waktu yang ditentukan. Ketika statistik Maksimum memiliki nilai 0 (nol), tidak ada catatan yang dibatasi untuk aliran selama periode waktu yang ditentukan. Nama metrik tingkat shard: `ReadProvisionedThroughputExceeded` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| SubscribeToShard.RateExceeded | Metrik ini dipancarkan ketika upaya berlangganan baru gagal karena sudah ada langganan aktif oleh konsumen yang sama atau jika Anda melebihi jumlah panggilan per detik yang diizinkan untuk operasi ini.Dimensi: StreamName, ConsumerName |
| SubscribeToShard.Success | Metrik ini mencatat apakah SubscribeToShard langganan berhasil dibuat. Langganan hanya hidup paling lama 5 menit. Oleh karena itu, metrik ini dipancarkan setidaknya sekali setiap 5 menit. Dimensi: StreamName, ConsumerName |
| SubscribeToShardEvent.Bytes | Jumlah byte yang diterima dari pecahan, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili byte yang diterbitkan dalam satu peristiwa untuk periode waktu yang ditentukan. Nama metrik tingkat shard: `OutgoingBytes` Dimensi: StreamName, ConsumerName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| SubscribeToShardEvent.MillisBehindLatest | Jumlah milidetik catatan baca berasal dari ujung aliran, menunjukkan seberapa jauh di belakang waktu konsumen saat ini. Dimensi: StreamName, ConsumerName Statistik: Minimum, Maksimum, Rata-rata, Sampel Unit: Milidetik |
| SubscribeToShardEvent.Records | Jumlah catatan yang diterima dari pecahan, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili catatan dalam satu peristiwa untuk periode waktu yang ditentukan. Nama metrik tingkat shard: `OutgoingRecords` Dimensi: StreamName, ConsumerName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| SubscribeToShardEvent.Success | Metrik ini dipancarkan setiap kali suatu peristiwa berhasil diterbitkan. Itu hanya dipancarkan ketika ada langganan aktif.Dimensi: StreamName, ConsumerNameStatistik: Minimum, Maksimum, Rata-rata, Jumlah, SampelUnit: Hitungan |
| WriteProvisionedThroughputExceeded | Jumlah catatan yang ditolak karena pelambatan untuk aliran selama periode waktu yang ditentukan. Metrik ini mencakup pembatasan dari `PutRecord` dan `PutRecords` operasi. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. Ketika statistik Minimum memiliki nilai bukan nol, catatan sedang dibatasi untuk aliran selama periode waktu yang ditentukan. Ketika statistik Maksimum memiliki nilai 0 (nol), tidak ada catatan yang dibatasi untuk aliran selama periode waktu yang ditentukan. Nama metrik tingkat shard: `WriteProvisionedThroughputExceeded` Dimensi: StreamName Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
### Metrik tingkat shard yang disempurnakan
`AWS/Kinesis`Namespace menyertakan metrik tingkat shard berikut.
Kinesis mengirimkan metrik level shard berikut ke setiap menit. CloudWatch Setiap dimensi metrik membuat 1 CloudWatch metrik dan membuat sekitar 43.200 panggilan `PutMetricData` API per bulan. Metrik ini tidak diaktifkan secara default. Ada biaya untuk metrik yang ditingkatkan yang dipancarkan dari Kinesis. Untuk informasi selengkapnya, lihat [ CloudWatch Harga Amazon](https://aws.amazon.com/cloudwatch/pricing/) di bawah judul *Metrik CloudWatch Kustom Amazon*. Biaya diberikan per pecahan per metrik per bulan.
| Metrik | Deskripsi |
| --- | --- |
| IncomingBytes | Jumlah byte berhasil dimasukkan ke pecahan selama periode waktu yang ditentukan. Metrik ini mencakup byte dari `PutRecord` dan `PutRecords` operasi. Statistik Minimum, Maksimum, dan Rata-rata mewakili byte dalam operasi put tunggal untuk pecahan dalam periode waktu yang ditentukan. Nama metrik tingkat aliran: `IncomingBytes` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| IncomingRecords | Jumlah catatan yang berhasil dimasukkan ke pecahan selama periode waktu yang ditentukan. Metrik ini mencakup jumlah rekor dari `PutRecord` dan `PutRecords` operasi. Statistik Minimum, Maksimum, dan Rata-rata mewakili catatan dalam operasi put tunggal untuk pecahan dalam periode waktu yang ditentukan. Nama metrik tingkat aliran: `IncomingRecords` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| IteratorAgeMilliseconds | Usia catatan terakhir dalam semua `GetRecords` panggilan yang dilakukan terhadap pecahan, diukur selama periode waktu yang ditentukan. Usia adalah perbedaan antara waktu saat ini dan kapan catatan terakhir `GetRecords` panggilan ditulis ke aliran. Statistik Minimum dan Maksimum dapat digunakan untuk melacak kemajuan aplikasi konsumen Kinesis. Nilai 0 (nol) menunjukkan bahwa catatan yang dibaca benar-benar terjebak dengan aliran. Nama metrik tingkat aliran: `GetRecords.IteratorAgeMilliseconds` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Sampel Unit: Milidetik |
| OutgoingBytes | Jumlah byte yang diambil dari pecahan, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili byte yang dikembalikan dalam satu `GetRecords` operasi atau diterbitkan dalam satu `SubscribeToShard` peristiwa untuk pecahan dalam periode waktu yang ditentukan. Nama metrik tingkat aliran: `GetRecords.Bytes` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Byte |
| OutgoingRecords | Jumlah catatan yang diambil dari pecahan, diukur selama periode waktu yang ditentukan. Statistik Minimum, Maksimum, dan Rata-rata mewakili catatan yang dikembalikan dalam satu `GetRecords` operasi atau diterbitkan dalam satu `SubscribeToShard` peristiwa untuk pecahan dalam periode waktu yang ditentukan. Nama metrik tingkat aliran: `GetRecords.Records` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| ReadProvisionedThroughputExceeded | Jumlah `GetRecords` panggilan dibatasi untuk pecahan selama periode waktu yang ditentukan. Jumlah pengecualian ini mencakup semua dimensi dari batas berikut: 5 pembacaan per pecahan per detik atau 2 MB per detik per pecahan. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. Ketika statistik Minimum memiliki nilai 1, semua catatan dibatasi untuk pecahan selama periode waktu yang ditentukan. Ketika statistik Maksimum memiliki nilai 0 (nol), tidak ada catatan yang dibatasi untuk pecahan selama periode waktu yang ditentukan. Nama metrik tingkat aliran: `ReadProvisionedThroughputExceeded` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
| WriteProvisionedThroughputExceeded | Jumlah catatan yang ditolak karena pelambatan untuk pecahan selama periode waktu yang ditentukan. Metrik ini mencakup pembatasan dari `PutRecord` dan `PutRecords` operasi dan mencakup semua dimensi dari batas berikut: 1.000 catatan per detik per pecahan atau 1 MB per detik per pecahan. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. Ketika statistik Minimum memiliki nilai bukan nol, catatan sedang dibatasi untuk pecahan selama periode waktu yang ditentukan. Ketika statistik Maksimum memiliki nilai 0 (nol), tidak ada catatan yang dibatasi untuk pecahan selama periode waktu yang ditentukan. Nama metrik tingkat aliran: `WriteProvisionedThroughputExceeded` Dimensi: StreamName, ShardId Statistik: Minimum, Maksimum, Rata-rata, Jumlah, Sampel Unit: Hitungan |
### Dimensi untuk metrik Amazon Kinesis Data Streams
| Dimensi | Deskripsi |
| --- | --- |
| StreamName | Nama pengaliran Kinesis. Semua statistik yang tersedia disaring oleh`StreamName`. |
### Metrik Aliran Data Kinesis Amazon yang Direkomendasikan
Beberapa metrik Amazon Kinesis Data Streams mungkin menarik bagi pelanggan Kinesis Data Streams. Daftar berikut menyediakan metrik yang direkomendasikan dan penggunaannya.
| Metrik | Catatan Penggunaan |
| --- | --- |
| `GetRecords.IteratorAgeMilliseconds` | Melacak posisi baca di semua pecahan dan konsumen di sungai. Jika usia iterator melewati 50% dari periode retensi (secara default, 24 jam, dapat dikonfigurasi hingga 7 hari), ada risiko kehilangan data karena kedaluwarsa rekaman. Kami menyarankan Anda menggunakan CloudWatch alarm pada statistik Maksimum untuk mengingatkan Anda sebelum kerugian ini berisiko. Untuk contoh skenario yang menggunakan metrik ini, lihat[Pemrosesan catatan konsumen tertinggal](troubleshooting-consumers.md#record-processing-falls-behind). |
| `ReadProvisionedThroughputExceeded` | Ketika pemrosesan catatan sisi konsumen Anda tertinggal, terkadang sulit untuk mengetahui di mana kemacetannya. Gunakan metrik ini untuk menentukan apakah pembacaan Anda sedang dibatasi karena melebihi batas throughput baca Anda. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. |
| WriteProvisionedThroughputExceeded | Ini untuk tujuan yang sama dengan ReadProvisionedThroughputExceeded metrik, tetapi untuk sisi produser (put) aliran. Statistik yang paling umum digunakan untuk metrik ini adalah Rata-rata. |
| PutRecord.Success, PutRecords.Success | Kami merekomendasikan penggunaan CloudWatch alarm pada statistik Rata-rata untuk menunjukkan kapan catatan gagal ke aliran. Pilih salah satu atau kedua jenis put tergantung pada apa yang digunakan produsen Anda. Jika menggunakan Amazon Kinesis Producer Library (KPL), gunakan. PutRecords.Success |
| GetRecords.Success | Sebaiknya gunakan CloudWatch alarm pada statistik Rata-rata untuk menunjukkan kapan catatan gagal dari aliran. |
## Akses CloudWatch metrik Amazon untuk Kinesis Data Streams
Anda dapat memantau metrik untuk Kinesis Data Streams menggunakan CloudWatch konsol, baris perintah, atau API. CloudWatch Prosedur berikut menunjukkan cara mengakses metrik menggunakan berbagai metode ini.
**Untuk mengakses metrik menggunakan konsol CloudWatch**
1. Buka CloudWatch konsol di [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/).
1. Pada bilah navigasi, pilih Wilayah.
1. Pada panel navigasi, silakan pilih **Metrik**.
1. **Di panel **CloudWatch Metrik menurut Kategori**, pilih Metrik Kinesis.**
1. Klik baris yang relevan untuk melihat statistik untuk yang ditentukan **MetricName**dan **StreamName**.
**Catatan:** Sebagian besar nama statistik konsol cocok dengan nama CloudWatch metrik terkait yang tercantum sebelumnya, kecuali untuk **Throughput Baca dan Throughput** **Tulis**. Statistik ini dihitung selama interval 5 menit: **Write Throughput** memantau `IncomingBytes` CloudWatch metrik, dan monitor **Read Throughput**. `GetRecords.Bytes`
1. (Opsional) Di panel grafik, pilih statistik dan periode waktu, lalu buat CloudWatch alarm menggunakan pengaturan ini.
**Untuk mengakses metrik menggunakan AWS CLI**
Gunakan [daftar-metrik](https://docs.aws.amazon.com/cli/latest/reference/cloudwatch/list-metrics.html) dan perintah. [get-metric-statistics](https://docs.aws.amazon.com/cli/latest/reference/cloudwatch/get-metric-statistics.html)
**Untuk mengakses metrik menggunakan CLI CloudWatch**
Gunakan [mon-list-metrics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/cli/cli-mon-list-metrics.html)dan [mon-get-stats](https://docs.aws.amazon.com/AmazonCloudWatch/latest/cli/cli-mon-get-stats.html)perintah.
**Untuk mengakses metrik menggunakan API CloudWatch**
Gunakan [ListMetrics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/API_ListMetrics.html)dan [GetMetricStatistics](https://docs.aws.amazon.com/AmazonCloudWatch/latest/APIReference/API_GetMetricStatistics.html)operasi.
# Pantau kesehatan Agen Aliran Data Kinesis dengan Amazon CloudWatch
Agen menerbitkan CloudWatch metrik kustom dengan namespace dari. **AWS KinesisAgent** Metrik ini membantu Anda menilai apakah agen mengirimkan data ke Kinesis Data Streams seperti yang ditentukan, dan apakah itu sehat dan mengkonsumsi jumlah CPU dan sumber daya memori yang sesuai pada produsen data. Metrik seperti jumlah catatan dan byte yang dikirim berguna untuk memahami tingkat di mana agen mengirimkan data ke aliran. Bila metrik ini turun di bawah ambang batas yang diharapkan sejumlah sekian persen atau turun ke nol, hal ini dapat menunjukkan masalah konfigurasi, kesalahan jaringan, atau masalah kondisi agen. Metrik seperti konsumsi CPU dan memori on-host serta penghitung kesalahan agen menunjukkan penggunaan sumber daya produsen data dan memberikan gambaran mengenai kemungkinan kesalahan konfigurasi atau host. Pada akhirnya, agen juga mencatat pengecualian layanan untuk membantu menyelidiki masalah agen. Metrik ini dilaporkan di Wilayah yang ditentukan dalam `cloudwatch.endpoint` setelan konfigurasi agen. CloudWatch metrik yang diterbitkan dari beberapa agen Kinesis dikumpulkan atau digabungkan. Untuk informasi selengkapnya tentang konfigurasi agen, silakan lihat [Tentukan pengaturan konfigurasi agen](writing-with-agents.md#agent-config-settings).
## Monitor dengan CloudWatch
Agen Kinesis Data Streams mengirimkan metrik berikut ke. CloudWatch
| Metrik | Deskripsi |
| --- | --- |
| BytesSent | Jumlah byte yang dikirim ke Kinesis Data Streams selama periode waktu yang ditentukan. Unit: Byte |
| RecordSendAttempts | Jumlah catatan yang dicoba (baik pertama kali, atau percobaan ulang) dalam panggilan ke `PutRecords` selama periode waktu yang ditentukan. Unit: Hitungan |
| RecordSendErrors | Jumlah catatan yang menghasilkan status gagal dalam panggilan ke `PutRecords`, termasuk percobaan ulang, selama periode waktu yang ditentukan. Unit: Hitungan |
| ServiceErrors | Jumlah panggilan ke `PutRecords` yang mengakibatkan kesalahan layanan (selain kesalahan throttling) selama periode waktu yang ditentukan. Unit: Hitungan |
# Log panggilan API Amazon Kinesis Data Streams dengan AWS CloudTrail
Amazon Kinesis Data Streams AWS CloudTrail terintegrasi dengan, layanan yang menyediakan catatan tindakan yang diambil oleh pengguna, peran, AWS atau layanan di Kinesis Data Streams. CloudTrail menangkap semua panggilan API untuk Kinesis Data Streams sebagai peristiwa. Panggilan yang diambil mencakup panggilan dari konsol Kinesis Data Streams dan panggilan kode ke operasi API Kinesis Data Streams. Jika Anda membuat jejak, Anda dapat mengaktifkan pengiriman CloudTrail peristiwa secara terus menerus ke bucket Amazon S3, termasuk peristiwa untuk Kinesis Data Streams. Jika Anda tidak mengonfigurasi jejak, Anda masih dapat melihat peristiwa terbaru di CloudTrail konsol dalam **Riwayat acara**. Dengan menggunakan informasi yang dikumpulkan oleh CloudTrail, Anda dapat menentukan permintaan yang dibuat untuk Kinesis Data Streams, alamat IP dari mana permintaan dibuat, siapa yang membuat permintaan, kapan dibuat, dan detail tambahan.
Untuk mempelajari selengkapnya CloudTrail, termasuk cara mengonfigurasi dan mengaktifkannya, lihat [Panduan AWS CloudTrail Pengguna](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/).
## Informasi Kinesis Data Streams di CloudTrail
CloudTrail diaktifkan di AWS akun Anda saat Anda membuat akun. Ketika aktivitas peristiwa yang didukung terjadi di Kinesis Data Streams, aktivitas tersebut direkam CloudTrail dalam suatu peristiwa bersama AWS dengan peristiwa layanan lainnya dalam riwayat **Peristiwa**. Anda dapat melihat, mencari, dan mengunduh acara terbaru di AWS akun Anda. Untuk informasi lain, lihat [Melihat Peristiwa dengan Riwayat Peristiwa CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/view-cloudtrail-events.html).
Untuk catatan peristiwa yang sedang berlangsung di AWS akun Anda, termasuk peristiwa untuk Kinesis Data Streams, buat jejak. *Jejak* memungkinkan CloudTrail untuk mengirimkan file log ke bucket Amazon S3. Secara default, saat Anda membuat jejak di konsol, jejak tersebut berlaku untuk semua AWS Wilayah. Jejak mencatat peristiwa dari semua Wilayah di AWS partisi dan mengirimkan file log ke bucket Amazon S3 yang Anda tentukan. Selain itu, Anda dapat mengonfigurasi AWS layanan lain untuk menganalisis lebih lanjut dan menindaklanjuti data peristiwa yang dikumpulkan dalam CloudTrail log. Untuk informasi selengkapnya, lihat berikut:
+ [Gambaran Umum untuk Membuat Jejak](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-create-and-update-a-trail.html)
+ [CloudTrail Layanan dan Integrasi yang Didukung](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-aws-service-specific-topics.html#cloudtrail-aws-service-specific-topics-integrations)
+ [Mengkonfigurasi Notifikasi Amazon SNS untuk CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/getting_notifications_top_level.html)
+ [Menerima File CloudTrail Log dari Beberapa Wilayah](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/receive-cloudtrail-log-files-from-multiple-regions.html) dan [Menerima File CloudTrail Log dari Beberapa Akun](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-receive-logs-from-multiple-accounts.html)
Kinesis Data Streams mendukung pencatatan tindakan berikut sebagai CloudTrail peristiwa dalam file log:
+ [AddTagsToStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_AddTagsToStream.html)
+ [CreateStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_CreateStream.html)
+ [DecreaseStreamRetentionPeriod](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DecreaseStreamRetentionPeriod.html)
+ [DeleteStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DeleteStream.html)
+ [DeregisterStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DeregisterStreamConsumer.html)
+ [DescribeStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DescribeStream.html)
+ [DescribeStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DescribeStreamConsumer.html)
+ [DisableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_DisableEnhancedMonitoring.html)
+ [EnableEnhancedMonitoring](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_EnableEnhancedMonitoring.html)
+ [GetRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html)
+ [GetShardIterator](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetShardIterator.html)
+ [IncreaseStreamRetentionPeriod](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_IncreaseStreamRetentionPeriod.html)
+ [ListStreamConsumers](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListStreamConsumers.html)
+ [ListStreams](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListStreams.html)
+ [ListTagsForStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_ListTagsForStream.html)
+ [MergeShards](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_MergeShards.html)
+ [PutRecord](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html)
+ [PutRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecords.html)
+ [RegisterStreamConsumer](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_RegisterStreamConsumer.html)
+ [RemoveTagsFromStream](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_RemoveTagsFromStream.html)
+ [SplitShard](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_SplitShard.html)
+ [StartStreamEncryption](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_StartStreamEncryption.html)
+ [StopStreamEncryption](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_StopStreamEncryption.html)
+ [SubscribeToShard](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_SubscribeToShard.html)
+ [UpdateShardCount](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_UpdateShardCount.html)
+ [UpdateStreamMode](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_UpdateStreamMode.html)
Setiap entri peristiwa atau log berisi informasi tentang entitas yang membuat permintaan tersebut. Informasi identitas membantu Anda menentukan hal berikut ini:
+ Apakah permintaan itu dibuat dengan kredenal pengguna root atau AWS Identity and Access Management (IAM).
+ Apakah permintaan tersebut dibuat dengan kredensial keamanan sementara untuk satu peran atau pengguna gabungan.
+ Apakah permintaan itu dibuat oleh AWS layanan lain.
Untuk informasi lain, lihat [Elemen userIdentity CloudTrail](https://docs.aws.amazon.com/awscloudtrail/latest/userguide/cloudtrail-event-reference-user-identity.html).
## Contoh: Entri file log Kinesis Data Streams
Trail adalah konfigurasi yang memungkinkan pengiriman peristiwa sebagai file log ke bucket Amazon S3 yang Anda tentukan. CloudTrail file log berisi satu atau lebih entri log. Sebuah kejadian mewakili permintaan tunggal dari sumber apa pun dan mencakup informasi tentang tindakan yang diminta, tanggal dan waktu tindakan, parameter permintaan, dan sebagainya. Berkas log CloudTrail bukan merupakan jejak tumpukan terurut dari panggilan API publik, sehingga tidak muncul dalam urutan tertentu.
Contoh berikut menunjukkan entri CloudTrail log yang menunjukkan`CreateStream`,,, `DescribeStream``ListStreams`, `DeleteStream``SplitShard`, dan `MergeShards` tindakan.
```
{
"Records": [
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:16:31Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "CreateStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"shardCount": 1,
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "db6c59f8-c757-11e3-bc3b-57923b443c1c",
"eventID": "b7acfcd0-6ca9-4ee1-a3d7-c4e8d420d99b"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:17:06Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "DescribeStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "f0944d86-c757-11e3-b4ae-25654b1d3136",
"eventID": "0b2f1396-88af-4561-b16f-398f8eaea596"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:15:02Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "ListStreams",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"limit": 10
},
"responseElements": null,
"requestID": "a68541ca-c757-11e3-901b-cbcfe5b3677a",
"eventID": "22a5fb8f-4e61-4bee-a8ad-3b72046b4c4d"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:17:07Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "DeleteStream",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream"
},
"responseElements": null,
"requestID": "f10cd97c-c757-11e3-901b-cbcfe5b3677a",
"eventID": "607e7217-311a-4a08-a904-ec02944596dd"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:15:03Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "SplitShard",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"shardToSplit": "shardId-000000000000",
"streamName": "GoodStream",
"newStartingHashKey": "11111111"
},
"responseElements": null,
"requestID": "a6e6e9cd-c757-11e3-901b-cbcfe5b3677a",
"eventID": "dcd2126f-c8d2-4186-b32a-192dd48d7e33"
},
{
"eventVersion": "1.01",
"userIdentity": {
"type": "IAMUser",
"principalId": "EX_PRINCIPAL_ID",
"arn": "arn:aws:iam::012345678910:user/Alice",
"accountId": "012345678910",
"accessKeyId": "EXAMPLE_KEY_ID",
"userName": "Alice"
},
"eventTime": "2014-04-19T00:16:56Z",
"eventSource": "kinesis.amazonaws.com",
"eventName": "MergeShards",
"awsRegion": "us-east-1",
"sourceIPAddress": "127.0.0.1",
"userAgent": "aws-sdk-java/unknown-version Linux/x.xx",
"requestParameters": {
"streamName": "GoodStream",
"adjacentShardToMerge": "shardId-000000000002",
"shardToMerge": "shardId-000000000001"
},
"responseElements": null,
"requestID": "e9f9c8eb-c757-11e3-bf1d-6948db3cd570",
"eventID": "77cf0d06-ce90-42da-9576-71986fec411f"
}
]
}
```
# Pantau Perpustakaan Klien Kinesis dengan Amazon CloudWatch
[Perpustakaan Klien Kinesis](https://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers-with-kcl.html) (KCL) untuk Amazon Kinesis Data Streams menerbitkan metrik CloudWatch Amazon kustom atas nama Anda, menggunakan nama aplikasi KCL Anda sebagai namespace. **Anda dapat melihat metrik ini dengan menavigasi ke [CloudWatch konsol](https://console.aws.amazon.com/cloudwatch/) dan memilih Metrik Kustom.** Untuk informasi selengkapnya tentang metrik kustom, lihat [Menerbitkan Metrik Kustom](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/publishingMetrics.html) di * CloudWatch Panduan Pengguna Amazon*.
Ada biaya nominal untuk metrik yang diunggah CloudWatch oleh KCL; khususnya, biaya Amazon * CloudWatch Custom Metrics dan CloudWatch Amazon* *API* Requests berlaku. Untuk informasi selengkapnya, lihat [ CloudWatch Harga Amazon](https://aws.amazon.com/cloudwatch/pricing/).
**Topics**
+ [Metrik dan namespace](#metrics-namespace)
+ [Tingkat dan dimensi metrik](#metric-levels)
+ [Konfigurasi metrik](#metrics-config)
+ [Daftar metrik](#kcl-metrics-list)
## Metrik dan namespace
Namespace yang digunakan untuk mengunggah metrik adalah nama aplikasi yang Anda tentukan saat meluncurkan KCL.
## Tingkat dan dimensi metrik
Ada dua opsi untuk mengontrol metrik mana yang diunggah: CloudWatch
tingkat metrik
Setiap metrik diberikan tingkat individu. Saat Anda menetapkan tingkat pelaporan metrik, metrik dengan tingkat individual di bawah tingkat pelaporan tidak akan dikirim. CloudWatch Levelnya adalah:`NONE`,`SUMMARY`, dan`DETAILED`. Pengaturan default adalah`DETAILED`; yaitu, semua metrik dikirim ke CloudWatch. Tingkat pelaporan `NONE` berarti tidak ada metrik yang dikirim sama sekali. Untuk informasi tentang level mana yang ditetapkan ke metrik apa, lihat[Daftar metrik](#kcl-metrics-list).
dimensi yang diaktifkan
Setiap metrik KCL memiliki dimensi terkait yang juga dikirim ke CloudWatch. Di KCL 2.x, jika KCL dikonfigurasi untuk memproses aliran data tunggal, semua dimensi metrik (`Operation`,`ShardId`, dan`WorkerIdentifier`) diaktifkan secara default. Juga, di KCL 2.x, jika KCL dikonfigurasi untuk memproses aliran data tunggal, `Operation` dimensi tidak dapat dinonaktifkan. Di KCL 2.x, jika KCL dikonfigurasi untuk memproses beberapa aliran data, semua dimensi metrik (`Operation`,, `ShardId``StreamId`, dan`WorkerIdentifier`) diaktifkan secara default. Juga, di KCL 2.x, jika KCL dikonfigurasi untuk memproses beberapa aliran data, `Operation` dan `StreamId` dimensi tidak dapat dinonaktifkan. `StreamId`dimensi hanya tersedia untuk metrik per-shard.
Di KCL 1.x, hanya `Operation` dan `ShardId` dimensi yang diaktifkan secara default, dan `WorkerIdentifier` dimensi dinonaktifkan. Di KCL 1.x, `Operation` dimensi tidak dapat dinonaktifkan.
Untuk informasi selengkapnya tentang dimensi CloudWatch metrik, lihat bagian [Dimensi](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#Dimension) dalam topik CloudWatch Konsep Amazon, di *Panduan CloudWatch Pengguna Amazon*.
Ketika `WorkerIdentifier` dimensi diaktifkan, jika nilai yang berbeda digunakan untuk properti ID pekerja setiap kali pekerja KCL tertentu memulai ulang, set metrik baru dengan nilai `WorkerIdentifier` dimensi baru akan dikirim ke. CloudWatch Jika Anda memerlukan nilai `WorkerIdentifier` dimensi yang sama di seluruh restart pekerja KCL tertentu, Anda harus secara eksplisit menentukan nilai ID pekerja yang sama selama inisialisasi untuk setiap pekerja. Perhatikan bahwa nilai ID pekerja untuk setiap pekerja KCL yang aktif harus unik di semua pekerja KCL.
## Konfigurasi metrik
Level metrik dan dimensi yang diaktifkan dapat dikonfigurasi menggunakan KinesisClientLibConfiguration instance, yang diteruskan ke Worker saat meluncurkan aplikasi KCL. MultiLangDaemon Dalam kasus ini, `metricsEnabledDimensions` properti `metricsLevel` and dapat ditentukan dalam file.properties yang digunakan untuk meluncurkan aplikasi MultiLangDaemon KCL.
Level metrik dapat diberikan salah satu dari tiga nilai: TIDAK ADA, RINGKASAN, atau DETAIL. Nilai dimensi yang diaktifkan harus berupa string yang dipisahkan koma dengan daftar dimensi yang diizinkan untuk metrik. CloudWatch Dimensi yang digunakan oleh aplikasi KCL adalah`Operation`,`ShardId`, dan`WorkerIdentifier`.
## Daftar metrik
Tabel berikut mencantumkan metrik KCL, dikelompokkan berdasarkan ruang lingkup dan operasi.
**Topics**
+ [Per-KCL-application metrik](#kcl-metrics-per-app)
+ [Metrik per pekerja](#kcl-metrics-per-worker)
+ [Metrik per shard](#kcl-metrics-per-shard)
### Per-KCL-application metrik
Metrik ini digabungkan di semua pekerja KCL dalam lingkup aplikasi, seperti yang didefinisikan oleh namespace Amazon. CloudWatch
**Topics**
+ [LeaseAssignmentManager](#lease-assignment-manager)
+ [InitializeTask](#init-task)
+ [ShutdownTask](#shutdown-task)
+ [ShardSyncTask](#shard-sync-task)
+ [BlockOnParentTask](#block-parent-task)
+ [PeriodicShardSyncManager](#periodic-task)
+ [MultistreamTracker](#multi-task)
#### LeaseAssignmentManager
`LeaseAssignmentManager`Operasi ini bertanggung jawab untuk menetapkan sewa kepada pekerja dan menyeimbangkan kembali sewa di antara pekerja untuk mencapai pemanfaatan sumber daya pekerja yang merata. Logika untuk operasi ini termasuk membaca metadata terkait sewa dari tabel sewa dan metrik dari tabel metrik pekerja, dan melakukan penugasan sewa.
| Metrik | Deskripsi |
| --- | --- |
| LeaseAndWorkerMetricsLoad.Waktu | Waktu yang dibutuhkan untuk memuat semua entri metrik sewa dan pekerja di manajer penugasan sewa (LAM), penugasan sewa baru dan algoritme penyeimbangan beban yang diperkenalkan di KCL 3.x. Tingkat metrik: Terperinci Unit: Milidetik |
| TotalLeases | Jumlah total sewa untuk aplikasi KCL saat ini. Tingkat metrik: Ringkasan Unit: Hitungan |
| NumWorkers | Jumlah total pekerja dalam aplikasi KCL saat ini. Tingkat metrik: Ringkasan Unit: Hitungan |
| AssignExpiredOrUnassignedLeases.Waktu | Waktu untuk melakukan penugasan dalam memori dari sewa yang kedaluwarsa. Tingkat metrik: Terperinci Unit: Milidetik |
| LeaseSpillover | Jumlah sewa yang tidak ditetapkan karena mencapai batas jumlah maksimum sewa atau throughput maksimum per pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| BalanceWorkerVariance.Waktu | Saatnya melakukan penyeimbangan sewa dalam memori antar pekerja. Tingkat metrik: Terperinci Unit: Milidetik |
| NumOfLeasesReassignment | Jumlah total penggantian sewa yang dilakukan dalam iterasi penugasan kembali saat ini. Tingkat metrik: Ringkasan Unit: Hitungan |
| FailedAssignmentCount | Jumlah kegagalan dalam AssignLease panggilan ke tabel sewa DynamoDB. Tingkat metrik: Terperinci Unit: Hitungan |
| ParallelyAssignLeases.Waktu | Saatnya menyiram tugas baru ke tabel sewa DynamoDB. Tingkat metrik: Terperinci Unit: Milidetik |
| ParallelyAssignLeases.Sukses | Jumlah pembilasan tugas baru yang berhasil. Tingkat metrik: Terperinci Unit: Hitungan |
| TotalStaleWorkerMetricsEntry | Jumlah total entri metrik pekerja yang harus dibersihkan. Tingkat metrik: Terperinci Unit: Hitungan |
| StaleWorkerMetricsCleanup.Waktu | Waktu untuk melakukan penghapusan entri metrik pekerja dari tabel metrik pekerja DynamoDB. Tingkat metrik: Terperinci Unit: Milidetik |
| Waktu | Waktu yang dibutuhkan oleh `LeaseAssignmentManager` operasi. Tingkat metrik: Ringkasan Unit: Milidetik |
| Berhasil | Berapa kali `LeaseAssignmentManager` operasi berhasil diselesaikan. Tingkat metrik: Ringkasan Unit: Hitungan |
| ForceLeaderRelease | Menunjukkan bahwa manajer penugasan sewa telah gagal 3 kali berturut-turut dan pekerja pemimpin melepaskan kepemimpinan. Tingkat metrik: Ringkasan Unit: Hitungan |
| NumWorkersWithInvalidEntry | Jumlah entri metrik pekerja yang dianggap tidak valid. Tingkat metrik: Ringkasan Unit: Hitungan |
| NumWorkersWithFailingWorkerMetric | Jumlah entri metrik pekerja yang memiliki -1 (mewakili nilai metrik pekerja tidak tersedia) sebagai salah satu nilai untuk metrik pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| LeaseDeserializationFailureCount | Entri sewa dari meja sewa yang gagal deserialisasi. Tingkat metrik: Ringkasan Unit: Hitungan |
#### InitializeTask
`InitializeTask`Operasi ini bertanggung jawab untuk menginisialisasi prosesor rekaman untuk aplikasi KCL. Logika untuk operasi ini termasuk mendapatkan iterator pecahan dari Kinesis Data Streams dan menginisialisasi prosesor rekaman.
| Metrik | Deskripsi |
| --- | --- |
| KinesisDataFetcher.getIterator.Success | Jumlah `GetShardIterator` operasi yang berhasil per aplikasi KCL. Tingkat metrik: Terperinci Unit: Hitungan |
| KinesisDataFetcher.getIterator.waktu | Waktu yang dibutuhkan per `GetShardIterator` operasi untuk aplikasi KCL yang diberikan. Tingkat metrik: Terperinci Unit: Milidetik |
| RecordProcessor.inisialize.waktu | Waktu yang dibutuhkan oleh metode inisialisasi prosesor rekaman. Tingkat metrik: Ringkasan Unit: Milidetik |
| Berhasil | Jumlah inisialisasi prosesor rekaman yang berhasil. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan oleh pekerja KCL untuk inisialisasi prosesor rekaman. Tingkat metrik: Ringkasan Unit: Milidetik |
#### ShutdownTask
`ShutdownTask`Operasi memulai urutan shutdown untuk pemrosesan shard. Hal ini dapat terjadi karena pecahan dipecah atau digabung, atau ketika sewa shard hilang dari pekerja. Dalam kedua kasus, `shutdown()` fungsi prosesor rekaman dipanggil. Pecahan baru juga ditemukan dalam kasus di mana pecahan dipecah atau digabungkan, menghasilkan penciptaan satu atau dua pecahan baru.
| Metrik | Deskripsi |
| --- | --- |
| CreateLease.Sukses | Berapa kali pecahan anak baru berhasil ditambahkan ke dalam tabel DynamoDB aplikasi KCL setelah shutdown shard induk. Tingkat metrik: Terperinci Unit: Hitungan |
| CreateLease.Waktu | Waktu yang dibutuhkan untuk menambahkan informasi pecahan anak baru dalam tabel DynamoDB aplikasi KCL. Tingkat metrik: Terperinci Unit: Milidetik |
| UpdateLease.Sukses | Jumlah pos pemeriksaan akhir yang berhasil selama shutdown prosesor rekaman. Tingkat metrik: Terperinci Unit: Hitungan |
| UpdateLease.Waktu | Waktu yang dibutuhkan oleh operasi pos pemeriksaan selama shutdown prosesor rekaman. Tingkat metrik: Terperinci Unit: Milidetik |
| RecordProcessor.shutdown.waktu | Waktu yang dibutuhkan oleh metode shutdown prosesor rekaman. Tingkat metrik: Ringkasan Unit: Milidetik |
| Berhasil | Jumlah tugas shutdown yang berhasil. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan oleh pekerja KCL untuk tugas shutdown. Tingkat metrik: Ringkasan Unit: Milidetik |
#### ShardSyncTask
`ShardSyncTask`Operasi menemukan perubahan informasi pecahan untuk aliran data Kinesis, sehingga pecahan baru dapat diproses oleh aplikasi KCL.
| Metrik | Deskripsi |
| --- | --- |
| CreateLease.Sukses | Jumlah upaya yang berhasil untuk menambahkan informasi pecahan baru ke dalam tabel DynamoDB aplikasi KCL. Tingkat metrik: Terperinci Unit: Hitungan |
| CreateLease.Waktu | Waktu yang dibutuhkan untuk menambahkan informasi pecahan baru dalam tabel DynamoDB aplikasi KCL. Tingkat metrik: Terperinci Unit: Milidetik |
| Berhasil | Jumlah operasi sinkronisasi shard yang berhasil. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan untuk operasi sinkronisasi shard. Tingkat metrik: Ringkasan Unit: Milidetik |
#### BlockOnParentTask
Jika pecahan dipecah atau digabung dengan pecahan lain, maka pecahan anak baru dibuat. `BlockOnParentTask`Operasi memastikan bahwa pemrosesan rekaman untuk pecahan baru tidak dimulai sampai pecahan induk benar-benar diproses oleh KCL.
| Metrik | Deskripsi |
| --- | --- |
| Berhasil | Jumlah pemeriksaan yang berhasil untuk penyelesaian pecahan induk. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan untuk penyelesaian pecahan induk. Tingkat metrik: Ringkasan Satuan: Milidetik |
#### PeriodicShardSyncManager
Bertanggung `PeriodicShardSyncManager` jawab untuk memeriksa aliran data yang sedang diproses oleh aplikasi konsumen KCL, mengidentifikasi aliran data dengan sewa sebagian dan menyerahkannya untuk sinkronisasi.
Metrik berikut tersedia ketika KCL dikonfigurasi untuk memproses aliran data tunggal (kemudian nilai NumStreamsToSync dan NumStreamsWithPartialLeases diatur ke 1) dan juga ketika KCL dikonfigurasi untuk memproses beberapa aliran data.
| Metrik | Deskripsi |
| --- | --- |
| NumStreamsToSync | Jumlah aliran data (per AWS akun) yang diproses oleh aplikasi konsumen yang berisi sewa sebagian dan yang harus diserahkan untuk sinkronisasi. Tingkat metrik: Ringkasan Unit: Hitungan |
| NumStreamsWithPartialLeases | Jumlah aliran data (per AWS akun) yang diproses aplikasi konsumen yang berisi sewa sebagian. Tingkat metrik: Ringkasan Unit: Hitungan |
| Berhasil | Berapa kali `PeriodicShardSyncManager` berhasil mengidentifikasi sewa sebagian dalam aliran data yang diproses oleh aplikasi konsumen. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Jumlah waktu (dalam milidetik) yang `PeriodicShardSyncManager` diperlukan untuk memeriksa aliran data yang diproses aplikasi konsumen, untuk menentukan aliran data mana yang memerlukan sinkronisasi pecahan. Tingkat metrik: Ringkasan Unit: Milidetik |
#### MultistreamTracker
`MultistreamTracker`Antarmuka memungkinkan Anda membangun aplikasi konsumen KCL yang dapat memproses beberapa aliran data secara bersamaan.
| Metrik | Deskripsi |
| --- | --- |
| DeletedStreams.Hitung | Jumlah aliran data yang dihapus pada periode waktu ini. Tingkat metrik: Ringkasan Unit: Hitungan |
| ActiveStreams.Hitung | Jumlah aliran data aktif yang sedang diproses. Tingkat metrik: Ringkasan Unit: Hitungan |
| StreamsPendingDeletion.Hitung | Jumlah aliran data yang tertunda penghapusan berdasarkan. `FormerStreamsLeasesDeletionStrategy` Tingkat metrik: Ringkasan Unit: Hitungan |
### Metrik per pekerja
Metrik ini dikumpulkan di semua prosesor rekaman yang menggunakan data dari aliran data Kinesis, seperti instans Amazon EC2.
**Topics**
+ [WorkerMetricStatsReporter](#worker-metrics-stats)
+ [LeaseDiscovery](#lease-discovery)
+ [RenewAllLeases](#renew-leases)
+ [TakeLeases](#take-leases)
#### WorkerMetricStatsReporter
`WorkerMetricStatReporter`Operasi bertanggung jawab untuk menerbitkan metrik pekerja saat ini secara berkala ke tabel metrik pekerja. Metrik ini digunakan oleh `LeaseAssignmentManager` operasi untuk melakukan penugasan sewa.
| Metrik | Deskripsi |
| --- | --- |
| InMemoryMetricStatsReporterFailure | Jumlah kegagalan untuk menangkap nilai metrik pekerja dalam memori, karena kegagalan beberapa metrik pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| WorkerMetricStatsReporter.Waktu | Waktu yang dibutuhkan oleh `WorkerMetricsStats` operasi. Tingkat metrik: Ringkasan Unit: Milidetik |
| WorkerMetricStatsReporter.Sukses | Berapa kali `WorkerMetricsStats` operasi berhasil diselesaikan. Tingkat metrik: Ringkasan Unit: Hitungan |
#### LeaseDiscovery
`LeaseDiscovery`Operasi bertanggung jawab untuk mengidentifikasi sewa baru yang diberikan kepada pekerja saat ini oleh `LeaseAssignmentManager` operasi. Logika untuk operasi ini melibatkan identifikasi sewa yang diberikan kepada pekerja saat ini dengan membaca indeks sekunder global dari tabel sewa.
| Metrik | Deskripsi |
| --- | --- |
| ListLeaseKeysForWorker.Waktu | Saatnya memanggil indeks sekunder global pada tabel sewa dan mendapatkan kunci sewa yang ditugaskan untuk pekerja saat ini. Tingkat metrik: Detil Unit: Milidetik |
| FetchNewLeases.Waktu | Saatnya mengambil semua sewa baru dari tabel sewa. Tingkat metrik: Detil Unit: Milidetik |
| NewLeasesDiscovered | Jumlah total sewa baru yang diberikan kepada pekerja. Tingkat metrik: Detil Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan oleh `LeaseDiscovery` operasi. Tingkat metrik: Ringkasan Unit: Milidetik |
| Berhasil | Berapa kali `LeaseDiscovery` operasi berhasil diselesaikan. Tingkat metrik: Ringkasan Unit: Hitungan |
| OwnerMismatch | Jumlah ketidakcocokan pemilik dari respons GSI dan tabel sewa dibaca konsisten. Tingkat metrik: Detil Unit: Hitungan |
#### RenewAllLeases
`RenewAllLeases`Operasi secara berkala memperbarui sewa pecahan yang dimiliki oleh contoh pekerja tertentu.
| Metrik | Deskripsi |
| --- | --- |
| RenewLease.Sukses | Jumlah perpanjangan sewa yang berhasil oleh pekerja. Tingkat metrik: Detil Unit: Hitungan |
| RenewLease.Waktu | Waktu yang dibutuhkan oleh operasi perpanjangan sewa. Tingkat metrik: Detil Unit: Milidetik |
| CurrentLeases | Jumlah sewa pecahan yang dimiliki oleh pekerja setelah semua sewa diperbarui. Tingkat metrik: Ringkasan Unit: Hitungan |
| LostLeases | Jumlah sewa pecahan yang hilang setelah upaya untuk memperbarui semua sewa yang dimiliki oleh pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| Berhasil | Berapa kali operasi pembaruan sewa berhasil bagi pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan untuk memperbarui semua sewa untuk pekerja. Tingkat metrik: Ringkasan Unit: Milidetik |
#### TakeLeases
`TakeLeases`Operasi menyeimbangkan pemrosesan catatan antara semua pekerja KCL. Jika pekerja KCL saat ini memiliki sewa pecahan yang lebih sedikit daripada yang dibutuhkan, dibutuhkan sewa pecahan dari pekerja lain yang kelebihan beban.
| Metrik | Deskripsi |
| --- | --- |
| ListLeases.Sukses | Berapa kali semua sewa shard berhasil diambil dari tabel DynamoDB aplikasi KCL. Tingkat metrik: Detil Unit: Hitungan |
| ListLeases.Waktu | Waktu yang dibutuhkan untuk mengambil semua sewa shard dari tabel DynamoDB aplikasi KCL. Tingkat metrik: Detil Unit: Milidetik |
| TakeLease.Sukses | Berapa kali pekerja berhasil mengambil sewa pecahan dari pekerja KCL lainnya. Tingkat metrik: Detil Unit: Hitungan |
| TakeLease.Waktu | Waktu yang dibutuhkan untuk memperbarui tabel sewa dengan sewa yang diambil oleh pekerja. Tingkat metrik: Detil Unit: Milidetik |
| NumWorkers | Jumlah total pekerja, sebagaimana diidentifikasi oleh pekerja tertentu. Tingkat metrik: Ringkasan Unit: Hitungan |
| NeededLeases | Jumlah sewa pecahan yang dibutuhkan pekerja saat ini untuk beban pemrosesan pecahan yang seimbang. Tingkat metrik: Detil Unit: Hitungan |
| LeasesToTake | Jumlah sewa yang akan diambil pekerja. Tingkat metrik: Detil Unit: Hitungan |
| TakenLeases | Jumlah sewa yang berhasil diambil oleh pekerja. Tingkat metrik: Ringkasan Unit: Hitungan |
| TotalLeases | Jumlah pecahan yang diproses aplikasi KCL. Tingkat metrik: Detil Unit: Hitungan |
| ExpiredLeases | Jumlah total pecahan yang tidak diproses oleh pekerja mana pun, sebagaimana diidentifikasi oleh pekerja tertentu. Tingkat metrik: Ringkasan Unit: Hitungan |
| Berhasil | Berapa kali `TakeLeases` operasi berhasil diselesaikan. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan oleh `TakeLeases` operasi untuk seorang pekerja. Tingkat metrik: Ringkasan Unit: Milidetik |
### Metrik per shard
Metrik ini dikumpulkan di satu prosesor rekaman.
#### ProcessTask
`ProcessTask`Operasi memanggil [GetRecords](https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html)dengan posisi iterator saat ini untuk mengambil catatan dari aliran dan memanggil fungsi prosesor rekaman. `processRecords`
| Metrik | Deskripsi |
| --- | --- |
| KinesisDataFetcher.getRecords.sukses | Jumlah `GetRecords` operasi yang berhasil per pecahan aliran data Kinesis. Tingkat metrik: Detil Unit: Hitungan |
| KinesisDataFetcher.getRecords.waktu | Waktu yang dibutuhkan per `GetRecords` operasi untuk pecahan aliran data Kinesis. Tingkat metrik: Detil Unit: Milidetik |
| UpdateLease.Sukses | Jumlah pos pemeriksaan yang berhasil dibuat oleh prosesor rekaman untuk pecahan yang diberikan. Tingkat metrik: Detil Unit: Hitungan |
| UpdateLease.Waktu | Waktu yang dibutuhkan untuk setiap operasi pos pemeriksaan untuk pecahan yang diberikan. Tingkat metrik: Detil Unit: Milidetik |
| DataBytesProcessed | Ukuran total catatan yang diproses dalam byte pada setiap `ProcessTask` pemanggilan. Tingkat metrik: Ringkasan Unit: Byte |
| RecordsProcessed | Jumlah catatan yang diproses pada setiap `ProcessTask` doa. Tingkat metrik: Ringkasan Unit: Hitungan |
| ExpiredIterator | Jumlah yang ExpiredIteratorException diterima saat menelepon`GetRecords`. Tingkat metrik: Ringkasan Unit: Hitungan |
| MillisBehindLatest | Waktu iterator saat ini tertinggal dari catatan terbaru (tip) di pecahan. Nilai ini kurang dari atau sama dengan perbedaan waktu antara catatan terbaru dalam respons dan waktu saat ini. Ini adalah refleksi yang lebih akurat tentang seberapa jauh pecahan dari ujung daripada membandingkan stempel waktu dalam catatan respons terakhir. Nilai ini berlaku untuk kumpulan catatan terbaru, bukan rata-rata semua stempel waktu di setiap catatan.Tingkat metrik: RingkasanUnit: Milidetik |
| RecordProcessor.ProcessRecords.time | Waktu yang dibutuhkan oleh `processRecords` metode prosesor rekaman. Tingkat metrik: Ringkasan Unit: Milidetik |
| Berhasil | Jumlah operasi tugas proses yang berhasil. Tingkat metrik: Ringkasan Unit: Hitungan |
| Waktu | Waktu yang dibutuhkan untuk operasi tugas proses. Tingkat metrik: Ringkasan Unit: Milidetik |
# Pantau Perpustakaan Produser Kinesis dengan Amazon CloudWatch
[Perpustakaan Produsen Amazon Kinesis](https://docs.aws.amazon.com/kinesis/latest/dev/developing-producers-with-kpl.html) (KPL) untuk Amazon Kinesis Data Streams menerbitkan metrik Amazon khusus atas nama Anda. CloudWatch **Anda dapat melihat metrik ini dengan menavigasi ke [CloudWatch konsol](https://console.aws.amazon.com/cloudwatch/) dan memilih Metrik Kustom.** Untuk informasi selengkapnya tentang metrik kustom, lihat [Menerbitkan Metrik Kustom](https://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/publishingMetrics.html) di * CloudWatch Panduan Pengguna Amazon*.
Ada biaya nominal untuk metrik yang diunggah CloudWatch oleh KPL; khususnya, biaya Amazon CloudWatch Custom Metrics dan CloudWatch Amazon API Requests berlaku. Untuk informasi selengkapnya, lihat [ CloudWatch Harga Amazon](https://aws.amazon.com/cloudwatch/pricing/). Pengumpulan metrik lokal tidak dikenakan biaya CloudWatch.
**Topics**
+ [Metrik, dimensi, dan ruang nama](#kpl-metrics)
+ [Tingkat metrik dan granularitas](#kpl-metrics-granularity)
+ [Akses lokal dan CloudWatch unggahan Amazon](#kpl-metrics-local-upload)
+ [Daftar metrik](#kpl-metrics-list)
## Metrik, dimensi, dan ruang nama
Anda dapat menentukan nama aplikasi saat meluncurkan KPL, yang kemudian digunakan sebagai bagian dari namespace saat mengunggah metrik. Ini opsional; KPL memberikan nilai default jika nama aplikasi tidak disetel.
Anda juga dapat mengonfigurasi KPL untuk menambahkan dimensi tambahan yang sewenang-wenang ke metrik. Ini berguna jika Anda menginginkan data berbutir halus dalam metrik Anda. CloudWatch Misalnya, Anda dapat menambahkan nama host sebagai dimensi, yang kemudian memungkinkan Anda mengidentifikasi distribusi beban yang tidak merata di seluruh armada Anda. Semua pengaturan konfigurasi KPL tidak dapat diubah, sehingga Anda tidak dapat mengubah dimensi tambahan ini setelah instance KPL diinisialisasi.
## Tingkat metrik dan granularitas
Ada dua opsi untuk mengontrol jumlah metrik yang diunggah ke: CloudWatch
*tingkat metrik*
Ini adalah ukuran kasar seberapa penting metrik. Setiap metrik diberi level. Saat Anda menetapkan level, metrik dengan level di bawah ini yang tidak dikirim ke CloudWatch. Levelnya adalah`NONE`,`SUMMARY`, dan`DETAILED`. Pengaturan default adalah`DETAILED`; yaitu, semua metrik. `NONE`berarti tidak ada metrik sama sekali, jadi tidak ada metrik yang benar-benar ditetapkan ke level itu.
*granularitas*
Ini mengontrol apakah metrik yang sama dipancarkan pada tingkat granularitas tambahan. Levelnya adalah`GLOBAL`,`STREAM`, dan`SHARD`. Pengaturan defaultnya adalah`SHARD`, yang berisi metrik paling granular.
Kapan `SHARD` dipilih, metrik dipancarkan dengan nama aliran dan ID pecahan sebagai dimensi. Selain itu, metrik yang sama juga dipancarkan hanya dengan dimensi nama aliran, dan metrik tanpa nama aliran. Ini berarti bahwa, untuk metrik tertentu, dua aliran dengan dua pecahan masing-masing akan menghasilkan tujuh CloudWatch metrik: satu untuk setiap pecahan, satu untuk setiap aliran, dan satu keseluruhan; semua menggambarkan statistik yang sama tetapi pada tingkat granularitas yang berbeda. Untuk ilustrasi, lihat diagram berikut.
Tingkat granularitas yang berbeda membentuk hierarki, dan semua metrik dalam sistem membentuk pohon, berakar pada nama metrik:
```
MetricName (GLOBAL): Metric X Metric Y
| |
----------------- ------------
| | | |
StreamName (STREAM): Stream A Stream B Stream A Stream B
| |
-------- ---------
| | | |
ShardID (SHARD): Shard 0 Shard 1 Shard 0 Shard 1
```
Tidak semua metrik tersedia pada tingkat pecahan; beberapa di antaranya adalah tingkat aliran atau global secara alami. Ini tidak diproduksi pada tingkat pecahan, bahkan jika Anda telah mengaktifkan metrik tingkat shard (`Metric Y`dalam diagram sebelumnya).
Saat Anda menentukan dimensi tambahan, Anda harus memberikan nilai untuk`tuple:`. Granularitas digunakan untuk menentukan di mana dimensi kustom dimasukkan dalam hierarki: `GLOBAL` berarti bahwa dimensi tambahan dimasukkan setelah nama metrik, `STREAM` berarti itu dimasukkan setelah nama aliran, dan `SHARD` berarti itu dimasukkan setelah ID pecahan. Jika beberapa dimensi tambahan diberikan per tingkat granularitas, mereka dimasukkan dalam urutan yang diberikan.
## Akses lokal dan CloudWatch unggahan Amazon
Metrik untuk instans KPL saat ini tersedia secara lokal secara real time; Anda dapat menanyakan KPL kapan saja untuk mendapatkannya. KPL secara lokal menghitung jumlah, rata-rata, minimum, maksimum, dan hitungan setiap metrik, seperti dalam. CloudWatch
Anda bisa mendapatkan statistik yang kumulatif dari awal program hingga saat ini dalam waktu, atau menggunakan jendela bergulir selama *N detik terakhir, di mana *N** adalah bilangan bulat antara 1 dan 60.
Semua metrik tersedia untuk diunggah. CloudWatch Ini sangat berguna untuk mengumpulkan data di beberapa host, pemantauan, dan mengkhawatirkan. Fungsi ini tidak tersedia secara lokal.
Seperti yang dijelaskan sebelumnya, Anda dapat memilih metrik mana yang akan diunggah dengan pengaturan *tingkat metrik* dan *granularitas*. Metrik yang tidak diunggah tersedia secara lokal.
Mengunggah titik data secara individual tidak dapat dipertahankan karena dapat menghasilkan jutaan unggahan per detik, jika lalu lintas tinggi. Untuk alasan ini, KPL menggabungkan metrik secara lokal ke dalam bucket 1 menit dan mengunggah objek statistik ke CloudWatch satu kali per menit, per metrik yang diaktifkan.
## Daftar metrik
| Metrik | Deskripsi |
| --- | --- |
| UserRecordsReceived | Hitung berapa banyak catatan pengguna logis yang diterima oleh inti KPL untuk operasi put. Tidak tersedia pada tingkat pecahan. Tingkat metrik: Detil Unit: Jumlah |
| UserRecordsPending | Sampel periodik berapa banyak catatan pengguna yang saat ini tertunda. Catatan tertunda jika saat ini di-buffer dan menunggu untuk dikirim, atau dikirim dan dalam penerbangan ke layanan backend. Tidak tersedia pada tingkat pecahan. KPL menyediakan metode khusus untuk mengambil metrik ini di tingkat global bagi pelanggan untuk mengelola tarif put mereka. Tingkat metrik: Detil Unit: Jumlah |
| UserRecordsPut | Hitung berapa banyak catatan pengguna logis yang berhasil dimasukkan. KPL menghasilkan nol untuk catatan yang gagal. Hal ini memungkinkan rata-rata untuk memberikan tingkat keberhasilan, hitungan untuk memberikan total upaya, dan perbedaan antara hitungan dan jumlah untuk memberikan hitungan kegagalan. Tingkat metrik: Ringkasan Unit: Jumlah |
| UserRecordsDataPut | Byte dalam catatan pengguna logis berhasil dimasukkan. Tingkat metrik: Detil Unit: Bita |
| KinesisRecordsPut | Hitungan berapa banyak catatan Kinesis Data Streams berhasil dimasukkan (setiap catatan Kinesis Data Streams dapat berisi beberapa catatan pengguna). KPL menghasilkan nol untuk catatan yang gagal. Hal ini memungkinkan rata-rata untuk memberikan tingkat keberhasilan, hitungan untuk memberikan total upaya, dan perbedaan antara hitungan dan jumlah untuk memberikan hitungan kegagalan. Tingkat metrik: Ringkasan Unit: Jumlah |
| KinesisRecordsDataPut | Byte dalam catatan Kinesis Data Streams. Tingkat metrik: Detil Unit: Bita |
| ErrorsByCode | Hitung setiap jenis kode kesalahan. Ini memperkenalkan dimensi tambahan`ErrorCode`, selain dimensi normal seperti `StreamName` dan`ShardId`. Tidak setiap kesalahan dapat ditelusuri ke pecahan. Kesalahan yang tidak dapat dilacak hanya dipancarkan pada tingkat aliran atau global. Metrik ini menangkap informasi tentang hal-hal seperti pelambatan, perubahan peta pecahan, kegagalan internal, layanan tidak tersedia, batas waktu, dan sebagainya. Kesalahan API Kinesis Data Streams dihitung satu kali per catatan Kinesis Data Streams. Beberapa catatan pengguna dalam catatan Kinesis Data Streams tidak menghasilkan beberapa hitungan. Tingkat metrik: Ringkasan Unit: Jumlah |
| AllErrors | Ini dipicu oleh kesalahan yang sama seperti **Errors by Code**, tetapi tidak membedakan antara tipe. Ini berguna sebagai monitor umum tingkat kesalahan tanpa memerlukan jumlah manual dari hitungan dari semua jenis kesalahan yang berbeda. Tingkat metrik: Ringkasan Unit: Jumlah |
| RetriesPerRecord | Jumlah percobaan ulang yang dilakukan per catatan pengguna. Nol dipancarkan untuk catatan yang berhasil dalam satu percobaan. Data dipancarkan pada saat catatan pengguna selesai (ketika berhasil atau tidak dapat lagi dicoba lagi). Jika catatan time-to-live adalah nilai yang besar, metrik ini mungkin tertunda secara signifikan. Tingkat metrik: Detil Unit: Jumlah |
| BufferingTime | Waktu antara catatan pengguna tiba di KPL dan berangkat ke backend. Informasi ini dikirimkan kembali ke pengguna berdasarkan per catatan, tetapi juga tersedia sebagai statistik agregat. Tingkat metrik: Ringkasan Satuan: Milidetik |
| Request Time | Waktu yang dibutuhkan untuk tampil`PutRecordsRequests`. Tingkat metrik: Detil Satuan: Milidetik |
| User Records per Kinesis Record | Jumlah catatan pengguna logis yang dikumpulkan ke dalam catatan Kinesis Data Streams tunggal. Tingkat metrik: Detil Unit: Jumlah |
| Amazon Kinesis Records per PutRecordsRequest | Jumlah catatan Kinesis Data Streams dikumpulkan menjadi satu. `PutRecordsRequest` Tidak tersedia pada tingkat pecahan. Tingkat metrik: Detil Unit: Jumlah |
| User Records per PutRecordsRequest | Jumlah total catatan pengguna yang terkandung dalam file`PutRecordsRequest`. Ini kira-kira setara dengan produk dari dua metrik sebelumnya. Tidak tersedia pada tingkat pecahan. Tingkat metrik: Detil Unit: Jumlah |