Memantau referensi data Azure Event Hubs

  • Artikel
  • 11 menit untuk membaca

Lihat Memantau Azure Event Hubs untuk detail tentang mengumpulkan dan menganalisis data pemantauan untuk Azure Event Hubs.

Catatan

Azure Monitor tidak menyertakan dimensi dalam data metrik yang diekspor, yang dikirim ke tujuan seperti Azure Storage, Azure Event Hubs, Log Analytics, dll.

Metrik

Bagian ini mencantumkan semua metrik platform yang dikumpulkan secara otomatis yang dikumpulkan untuk Azure Event Hubs. Penyedia sumber daya untuk metrik ini adalah Microsoft.EventHub/clusters atau Microsoft.EventHub/clusters.

Metrik permintaan

Menghitung jumlah permintaan operasi data dan manajemen.

Nama Metrik Dapat diekspor melalui pengaturan diagnostik Unit Jenis agregasi Deskripsi Dimensi
Permintaan Masuk Ya Menghitung Total Jumlah permintaan yang dibuat untuk layanan Azure Event Hubs selama periode tertentu. Metrik ini mencakup semua operasi bidang manajemen dan data. Nama entitas
Permintaan Berhasil Tidak Menghitung Total Jumlah permintaan berhasil yang dibuat untuk layanan Azure Event Hubs selama periode tertentu. Nama entitas

Hasil Operasi
Permintaan Dibatasi Tidak Menghitung Total Jumlah permintaan yang dibatasi karena penggunaannya terlampaui. Nama entitas

Hasil Operasi

Dua jenis kesalahan berikut diklasifikasikan sebagai kesalahan pengguna:

  1. Kesalahan sisi klien (Dalam HTTP yang akan menjadi kesalahan 400).
  2. Kesalahan yang terjadi saat memproses pesan.

Metrik pesan

Nama Metrik Dapat diekspor melalui pengaturan diagnostik Unit Jenis agregasi Deskripsi Dimensi
Pesan Masuk Ya Menghitung Total Jumlah peristiwa atau pesan yang dikirim ke Azure Event Hubs selama periode tertentu. Nama entitas
Pesan Keluar Ya Menghitung Total Jumlah peristiwa atau pesan yang diterima dari Azure Event Hubs selama periode tertentu. Nama entitas
Pesan yang Diambil Tidak Menghitung Total Jumlah pesan yang diambil. Nama entitas
Byte Masuk Ya Byte Total Byte masuk untuk hub kejadian selama periode tertentu. Nama entitas
Byte Keluar Ya Byte Total Byte keluar untuk hub kejadian selama periode tertentu. Nama entitas
Ukuran Tidak Byte Rata-rata Ukuran hub kejadian di byte. Nama entitas

Catatan

  • Nilai-nilai ini adalah nilai point-in-time. Pesan masuk yang dikonsumsi segera setelah point-in-time tersebut mungkin tidak tercermin dalam metrik ini.
  • Metrik Permintaan masuk mencakup semua operasi bidang manajemen dan data. Metrik Pesan masuk memberi Anda total jumlah peristiwa yang dikirimkan ke hub peristiwa. Misalnya, jika Anda mengirimkan batch 100 peristiwa ke hub peristiwa, itu akan dihitung sebagai 1 permintaan masuk dan 100 pesan masuk.

Ambil metrik

Nama Metrik Dapat diekspor melalui pengaturan diagnostik Unit Jenis agregasi Deskripsi Dimensi
Pesan yang Diambil Tidak Menghitung Total Jumlah pesan yang diambil. Nama entitas
Byte yang Diambil Tidak Byte Total Byte yang diambil untuk pusat peristiwa Nama entitas
Ambil Backlog Tidak Menghitung Total Mengambil backlog untuk pusat peristiwa Nama entitas

Metrik koneksi

Nama Metrik Dapat diekspor melalui pengaturan diagnostik Unit Jenis agregasi Deskripsi Dimensi
Sambungan Aktif Tidak Menghitung Rata-rata Jumlah koneksi aktif pada namespace dan pada entitas (hub kejadian) di namespace. Nilai untuk metrik ini adalah nilai point-in-time. Koneksi yang aktif segera setelah point-in-time tersebut mungkin tidak tercermin dalam metrik. Nama entitas
Sambungan Dibuka Tidak Menghitung Rata-rata Jumlah koneksi terbuka. Nama entitas
Sambungan Ditutup Tidak Menghitung Rata-rata Jumlah sambungan ditutup. Nama entitas

Metrik kesalahan

Nama Metrik Dapat diekspor melalui pengaturan diagnostik Unit Jenis agregasi Deskripsi Dimensi
Kesalahan Server Tidak Menghitung Total Jumlah permintaan yang tidak diproses karena kesalahan dalam layanan Azure Event Hubs selama periode tertentu. Nama entitas

Hasil Operasi
Kesalahan Pengguna Tidak Menghitung Total Jumlah permintaan yang tidak diproses karena kesalahan pengguna selama periode tertentu. Nama entitas

Hasil Operasi
Kesalahan Melebihi Kuota Tidak Menghitung Total Jumlah kesalahan yang disebabkan karena melebihi kuota selama periode tertentu. Nama entitas

Hasil Operasi

Catatan

Logic Apps menciptakan penerima epoch dan penerima dapat dipindahkan dari satu node ke node lainnya tergantung pada beban layanan. Selama perpindahan tersebut, pengecualian ReceiverDisconnection dapat terjadi. Pengecualian ini dihitung sebagai kesalahan pengguna di sisi layanan Event Hubs. Logic Apps dapat mengumpulkan kegagalan dari klien Event Hubs sehingga Anda dapat melihatnya di log pengguna.

Dimensi metrik

Azure Event Hubs mendukung dimensi berikut untuk metrik di Azure Monitor. Menambahkan dimensi ke metrik Anda bersifat opsional. Jika Anda tidak menambahkan dimensi, metrik ditentukan pada tingkat namespace.

Nama dimensi Deskripsi
Nama Entitas Nama hub kejadian.

Log sumber daya

Pusat Aktivitas menangkap log diagnostik untuk kategori berikut:

Kategori Deskripsi
Log Arsip Menangkap informasi tentang operasi Menangkap Pusat Aktivitas, khususnya log yang terkait dengan kesalahan penangkapan.
Log Operasional Menangkap semua operasi manajemen yang dilakukan di namespace Azure Event Hubs. Operasi data tidak ditangkap, karena tingginya volume operasi data yang dilakukan di Azure Event Hubs.
Log skala otomatis Menangkap operasi inflate otomatis yang dilakukan pada namespace Pusat Aktivitas.
Log koordinator Kafka Menangkap operasi koordinator Kafka yang terkait dengan Pusat Aktivitas.
Log kesalahan pengguna Kafka Menangkap informasi tentang API Kafka yang dipanggil di Pusat Aktivitas.
Kejadian koneksi jaringan virtual (VNet) Pusat Aktivitas Menangkap informasi tentang alamat IP dan jaringan virtual yang mengirim lalu lintas ke Pusat Aktivitas.
Log pengguna kunci yang dikelola pelanggan Menangkap operasi yang terkait dengan kunci yang dikelola pelanggan.

Semua log disimpan dalam format JavaScript Object Notation (JSON). Setiap entri memiliki bidang string yang menggunakan format yang dijelaskan di bagian berikut ini.

Skema log arsip

String JSON log arsip menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
TaskName Deskripsi tugas yang gagal
ActivityId ID internal, digunakan untuk pelacakan
trackingId ID internal, digunakan untuk pelacakan
resourceId ID sumber daya Azure Resource Manager
eventHub Nama lengkap pusat aktivitas (termasuk nama namespace)
partitionId Partisi Pusat Aktivitas sedang ditulis ke
archiveStep nilai yang mungkin: ArchiveFlushWriter, DestinationInit
startTime Waktu mulai kegagalan
failures Berapa kali kegagalan terjadi
durationInSeconds Durasi kegagalan
message Pesan kesalahan
category ArchiveLogs

Kode berikut adalah contoh string JSON log arsip:

{
   "TaskName": "EventHubArchiveUserError",
   "ActivityId": "000000000-0000-0000-0000-0000000000000",
   "trackingId": "0000000-0000-0000-0000-00000000000000000",
   "resourceId": "/SUBSCRIPTIONS/000000000-0000-0000-0000-0000000000000/RESOURCEGROUPS/<Resource Group Name>/PROVIDERS/MICROSOFT.EVENTHUB/NAMESPACES/<Event Hubs Namespace Name>",
   "eventHub": "<Event Hub full name>",
   "partitionId": "1",
   "archiveStep": "ArchiveFlushWriter",
   "startTime": "9/22/2016 5:11:21 AM",
   "failures": 3,
   "durationInSeconds": 360,
   "message": "Microsoft.WindowsAzure.Storage.StorageException: The remote server returned an error: (404) Not Found. ---> System.Net.WebException: The remote server returned an error: (404) Not Found.\r\n   at Microsoft.WindowsAzure.Storage.Shared.Protocol.HttpResponseParsers.ProcessExpectedStatusCodeNoException[T](HttpStatusCode expectedStatusCode, HttpStatusCode actualStatusCode, T retVal, StorageCommandBase`1 cmd, Exception ex)\r\n   at Microsoft.WindowsAzure.Storage.Blob.CloudBlockBlob.<PutBlockImpl>b__3e(RESTCommand`1 cmd, HttpWebResponse resp, Exception ex, OperationContext ctx)\r\n   at Microsoft.WindowsAzure.Storage.Core.Executor.Executor.EndGetResponse[T](IAsyncResult getResponseResult)\r\n   --- End of inner exception stack trace ---\r\n   at Microsoft.WindowsAzure.Storage.Core.Util.StorageAsyncResult`1.End()\r\n   at Microsoft.WindowsAzure.Storage.Core.Util.AsyncExtensions.<>c__DisplayClass4.<CreateCallbackVoid>b__3(IAsyncResult ar)\r\n--- End of stack trace from previous location where exception was thrown ---\r\n   at System.",
   "category": "ArchiveLogs"
}

Skema log operasional

String JSON log arsip menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
ActivityId ID internal, digunakan untuk pelacakan
EventName Nama operasi. Untuk daftar nilai untuk elemen ini, lihat Nama aktivitas
resourceId ID sumber daya Azure Resource Manager
SubscriptionId ID Langganan
EventTimeString Waktu operasi
EventProperties Properti untuk operasi ini. Elemen ini menyediakan informasi selengkapnya tentang aktivitas seperti yang diperlihatkan dalam contoh berikut.
Status Status operasi. Nilai bisa Berhasil atau Gagal.
Caller Pemanggil operasi (portal Azure atau klien manajemen)
Category OperasionalLogs

Kode berikut adalah contoh string JSON log arsip:

Example:
{
   "ActivityId": "00000000-0000-0000-0000-00000000000000",
   "EventName": "Create EventHub",
   "resourceId": "/SUBSCRIPTIONS/00000000-0000-0000-0000-0000000000000/RESOURCEGROUPS/<Resource Group Name>/PROVIDERS/MICROSOFT.EVENTHUB/NAMESPACES/<Event Hubs namespace name>",
   "SubscriptionId": "000000000-0000-0000-0000-000000000000",
   "EventTimeString": "9/28/2016 8:40:06 PM +00:00",
   "EventProperties": "{\"SubscriptionId\":\"0000000000-0000-0000-0000-000000000000\",\"Namespace\":\"<Namespace Name>\",\"Via\":\"https://<Namespace Name>.servicebus.windows.net/f8096791adb448579ee83d30e006a13e/?api-version=2016-07\",\"TrackingId\":\"5ee74c9e-72b5-4e98-97c4-08a62e56e221_G1\"}",
   "Status": "Succeeded",
   "Caller": "ServiceBus Client",
   "category": "OperationalLogs"
}

Nama kejadian

Nama kejadian diisi sebagai tipe operasi + tipe sumber daya dari enumerasi berikut. Misalnya, Create Queue, Retrieve Event Hu, atau Delete Rule.

Jenis operasi Jenis Sumber Daya
  • Buat
  • Pembaruan
  • Hapus
  • Mengambil
  • Tidak dikenal
  • Ruang nama
  • Antrean
  • Topik
  • Langganan
  • EventHub
  • EventHubSubscription
  • NotificationHub
  • NotificationHubTier
  • SharedAccessPolicy
  • UsageCredit
  • NamespacePnsCredentials
    • AturanConsumerGroup

Skema log skala otomatis

Log skala otomatis JSON menyertakan elemen yang tercantum dalam tabel berikut ini:

Nama Deskripsi
TrackingId ID Internal, yang digunakan untuk tujuan pelacakan
ResourceId ID sumber daya Azure Resource Manager.
Message Pesan informasi, yang menyediakan detail tentang tindakan inflate otomatis. Pesan tersebut berisi nilai unit throughput sebelumnya dan saat ini untuk namespace tertentu dan apa yang memicu inflate TU.

Berikut ini contoh kejadian skala otomatis:

{
    "TrackingId": "fb1b3676-bb2d-4b17-85b7-be1c7aa1967e",
    "Message": "Scaled-up EventHub TUs (UpdateStartTimeUTC: 5/13/2021 7:48:36 AM, PreviousValue: 1, UpdatedThroughputUnitValue: 2, AutoScaleReason: 'IncomingMessagesPerSecond reached 2170')",
    "ResourceId": "/subscriptions/0000000-0000-0000-0000-000000000000/resourcegroups/testrg/providers/microsoft.eventhub/namespaces/namespace-name"
}

Skema log koordinator Kafka

Log koordinator Kafka JSON menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
RequestId ID Permintaan, yang digunakan untuk tujuan pelacakan
ResourceId ID sumber daya Azure Resource Manager
Operation Nama operasi yang dilakukan selama koordinasi grup
ClientId ID Klien
NamespaceName Nama namespace
SubscriptionId ID langganan Azure
Message Pesan informasi atau peringatan, yang memberikan rincian tentang tindakan yang dilakukan selama koordinasi grup.

Contoh

{
    "RequestId": "FE01001A89E30B020000000304620E2A_KafkaExampleConsumer#0",
    "Operation": "Join.Start",
    "ClientId": "KafkaExampleConsumer#0",
    "Message": "Start join group for new member namespace-name:c:$default:I:KafkaExampleConsumer#0-cc40856f7f3c4607915a571efe994e82, current group size: 0, API version: 2, session timeout: 10000ms, rebalance timeout: 300000ms.",
    "SubscriptionId": "0000000-0000-0000-0000-000000000000",
    "NamespaceName": "namespace-name",
    "ResourceId": "/subscriptions/0000000-0000-0000-0000-000000000000/resourcegroups/testrg/providers/microsoft.eventhub/namespaces/namespace-name",
    "Category": "KafkaCoordinatorLogs"
}

Skema log kesalahan pengguna Kafka

Log kesalahan pengguna Kafka JSON menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
TrackingId ID Penelusuran, yang digunakan untuk tujuan pelacakan.
NamespaceName Nama namespace
Eventhub Nama pusat aktivitas
PartitionId ID Partisi
GroupId ID Grup
ClientId ID Klien
ResourceId ID sumber daya Azure Resource Manager.
Message Pesan informasi, yang menyediakan detail tentang kesalahan

Skema kejadian koneksi jaringan virtual Pusat Aktivitas

Kejadian koneksi jaringan virtual Pusat Aktivitas (VNet) JSON menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
SubscriptionId ID langganan Azure
NamespaceName Nama namespace
IPAddress Alamat IP klien yang tersambung ke layanan Pusat Aktivitas
Action Tindakan yang dilakukan oleh layanan Pusat Aktivitas saat mengevaluasi permintaan koneksi. Tindakan yang didukung adalah Terima Koneksi dan Tolak Koneksi.
Reason Memberikan alasan mengapa tindakan dilakukan
Count Jumlah kemunculan untuk tindakan yang diberikan
ResourceId ID sumber daya Azure Resource Manager.

Log jaringan virtual dibuat hanya jika namespace memungkinkan akses dari jaringan yang dipilih atau dari alamat IP tertentu (aturan filter IP). Jika Anda tidak ingin membatasi akses ke namespace Anda menggunakan fitur-fitur ini dan masih ingin mendapatkan log jaringan virtual untuk melacak alamat IP klien yang terhubung ke namespace Pusat Aktivitas, Anda bisa menggunakan solusi sementara berikut ini. Aktifkan pemfilteran IP, dan tambahkan total rentang IPv4 yang dapat diatasi (1.0.0.0/1 - 255.0.0.0/1). Pemfilteran IP Pusat Aktivitas tidak mendukung rentang IPv6. Anda mungkin melihat alamat titik akhir privat dalam format IPv6 di log.

Contoh

{
    "SubscriptionId": "0000000-0000-0000-0000-000000000000",
    "NamespaceName": "namespace-name",
    "IPAddress": "1.2.3.4",
    "Action": "Deny Connection",
    "Reason": "IPAddress doesn't belong to a subnet with Service Endpoint enabled.",
    "Count": "65",
    "ResourceId": "/subscriptions/0000000-0000-0000-0000-000000000000/resourcegroups/testrg/providers/microsoft.eventhub/namespaces/namespace-name",
    "Category": "EventHubVNetConnectionEvent"
}

Skema log pengguna kunci yang dikelola pelanggan

Log pengguna kunci yang dikelola pelanggan JSON menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
Category Jenis kategori untuk pesan. Hal ini salah satu dari nilai berikut: error dan info. Misalnya, jika kunci dari brankas kunci Anda sedang dinonaktifkan, maka itu akan menjadi kategori informasi atau jika kunci tidak dapat dibuka, itu bisa jatuh di bawah kesalahan.
ResourceId ID sumber daya internal, yang menyertakan ID langganan Azure dan nama namespace
KeyVault Nama sumber daya Key Vault
Key Nama kunci Key Vault yang digunakan untuk mengenkripsi namespace Azure Event Hubs.
Version Versi kunci Key Vault
Operation Operasi yang dilakukan pada kunci di brankas kunci Anda. Misalnya, nonaktifkan/aktifkan kunci, bungkus, atau buka bungkus.
Code Kode yang terkait dengan operasi. Contoh: Kode galat, 404 berarti kunci tersebut tidak ditemukan.
Message Pesan informasi, yang menyediakan detail tentang kesalahan atau pesan informatif

Berikut adalah contoh log untuk kunci yang dikelola pelanggan:

{
   "TaskName": "CustomerManagedKeyUserLog",
   "ActivityId": "11111111-1111-1111-1111-111111111111",
   "category": "error"
   "resourceId": "/SUBSCRIPTIONS/11111111-1111-1111-1111-11111111111/RESOURCEGROUPS/DEFAULT-EVENTHUB-CENTRALUS/PROVIDERS/MICROSOFT.EVENTHUB/NAMESPACES/FBETTATI-OPERA-EVENTHUB",
   "keyVault": "https://mykeyvault.vault-int.azure-int.net",
   "key": "mykey",
   "version": "1111111111111111111111111111111",
   "operation": "wrapKey",
   "code": "404",
   "message": "Key not found: ehbyok0/111111111111111111111111111111",
}



{
   "TaskName": "CustomerManagedKeyUserLog",
   "ActivityId": "11111111111111-1111-1111-1111111111111",
   "category": "info"
   "resourceId": "/SUBSCRIPTIONS/111111111-1111-1111-1111-11111111111/RESOURCEGROUPS/DEFAULT-EVENTHUB-CENTRALUS/PROVIDERS/MICROSOFT.EVENTHUB/NAMESPACES/FBETTATI-OPERA-EVENTHUB",
   "keyVault": "https://mykeyvault.vault-int.azure-int.net",
   "key": "mykey",
   "version": "111111111111111111111111111111",
   "operation": "disable" | "restore",
   "code": "",
   "message": "",
}

Berikut ini adalah kode galat umum yang harus diwawasi ketika enkripsi BYOK diaktifkan.

Tindakan Kode kesalahan Hasil status data
Hapus izin bungkus/buka pembungkusan dari brankas kunci 403 Tidak dapat diakses
Menghapus keanggotaan peran AAD dari perwakilan AAD yang memberikan izin bungkus/buka 403 Tidak dapat diakses
Hapus kunci enkripsi dari brankas kunci 404 Tidak dapat diakses
Hapus brankas kunci 404 Tidak dapat diakses (menganggap penghapusan sementara diaktifkan, yang merupakan pengaturan yang diperlukan.)
Mengubah periode kedaluwarsa pada kunci enkripsi sehingga sudah kedaluwarsa 403 Tidak dapat diakses
Mengubah NBF (sebelum) sehingga kunci enkripsi kunci tidak aktif 403 Tidak dapat diakses
Memilih opsi Izinkan Layanan MSFT untuk firewall brankas kunci atau memblokir akses jaringan ke brankas kunci yang memiliki kunci enkripsi 403 Tidak dapat diakses
Memindahkan brankas kunci ke penyewa lain 404 Tidak dapat diakses
Masalah jaringan terputus-putus atau pemadaman DNS/AAD/MSI Dapat diakses menggunakan kunci enkripsi data cache

Log audit runtime

Log audit runtime menangkap informasi diagnostik gabungan untuk semua operasi akses bidang data (seperti mengirim atau menerima peristiwa) di Event Hubs.

Catatan

Log audit runtime hanya tersedia di tingkat premium dan khusus.

Log audit runtime menyertakan elemen yang tercantum dalam tabel berikut:

Nama Deskripsi
ActivityId UUID yang dibuat secara acak yang memastikan keunikan untuk aktivitas audit.
ActivityName Nama operasi runtime.
ResourceId Sumber daya terkait dengan aktivitas.
Timestamp Waktu agregasi.
Status Status aktivitas (berhasil atau gagal).
Protocol Tipe protokol terkait dengan operasi.
AuthType Tipe autentikasi (Azure Active Directory atau Kebijakan SAS).
AuthKey ID aplikasi Azure Active Directory atau nama kebijakan SAS yang digunakan untuk melakukan autentikasi ke sumber daya.
NetworkType Jenis akses jaringan: Public atau Private.
ClientIP Alamat IP aplikasi klien.
Count Total jumlah operasi yang dijalankan selama periode agregat selama 1 menit.
Properties Metadata yang ditujukan khusus untuk operasi data plane.
Category Kategori log

Berikut adalah contoh entri log audit runtime:

{
    "ActivityId": "<activity id>",
    "ActivityName": "ConnectionOpen | Authorization | SendMessage | ReceiveMessage",
    "ResourceId": "/SUBSCRIPTIONS/xxx/RESOURCEGROUPS/<Resource Group Name>/PROVIDERS/MICROSOFT.EVENTHUB/NAMESPACES/<Event Hubs namespace>/eventhubs/<event hub name>",
    "Time": "1/1/2021 8:40:06 PM +00:00",
    "Status": "Success | Failure",
    "Protocol": "AMQP | KAFKA | HTTP | Web Sockets", 
    "AuthType": "SAS | Azure Active Directory", 
    "AuthId": "<AAD application name | SAS policy name>",
    "NetworkType": "Public | Private", 
    "ClientIp": "x.x.x.x",
    "Count": 1,
    "Category": "RuntimeAuditLogs"
 }

Log metrik aplikasi

Log metrik aplikasi merekam informasi agregat terkait metrik tertentu yang terkait dengan operasi data plane. Informasi yang direkam mencakup metrik runtime berikut.

Catatan

Log metrik aplikasi hanya tersedia di tingkat premium dan khusus.

Nama Deskripsi
ConsumerLag Menunjukkan jeda antara konsumen dan produser.
NamespaceActiveConnections Detail koneksi aktif yang dibuat dari klien ke pusat peristiwa.
GetRuntimeInfo Dapatkan informasi durasi dari Azure Event Hubs.
GetPartitionRuntimeInfo Dapatkan perkiraan informasi runtime untuk partisi logika dari pusat peristiwa.

Tabel log Azure Monitor

Azure Event Hubs menggunakan tabel Kusto dari Azure Monitor Logs. Anda dapat mengkueri tabel ini dengan Analitik Log. Untuk daftar penggunaan layanan tabel Kusto, lihat referensi tabel Azure Monitor Logs.

Penting

Dimensi tidak diekspor ke ruang kerja Analitik Log.

Langkah berikutnya