Menggunakan pemadatan log

Artikel
06/19/2023

Artikel ini memperlihatkan kepada Anda cara menggunakan fitur pemadatan log di Azure Event Hubs. Untuk memahami detail pemadatan log, lihat Pemadatan Log.

Dalam artikel ini Anda akan, ikuti langkah-langkah utama berikut:

Buat topik event hub/Kafka yang dikompilasi.
Menerbitkan peristiwa ke pusat aktivitas yang dikompresi.
Mengonsumsi peristiwa dari pusat aktivitas yang dikompresi.

Catatan

Fitur pemadatan log tidak didukung di tingkat Dasar .

Membuat topik pusat aktivitas/Kafka yang dikompilasi

Bagian ini memperlihatkan kepada Anda cara membuat hub peristiwa yang dikompilasi menggunakan portal Azure dan templat Azure Resource Manager (ARM).

portal Microsoft Azure
Templat ARM

Anda dapat membuat hub peristiwa yang dikompilasi menggunakan portal Azure dengan mengikuti langkah-langkah ini.

Navigasikan ke namespace Pusat Aktivitas Anda.
Pada halaman Kumpulan Nama Event Hubs, pilih Event Hubs di menu sebelah kiri.
Di bagian atas jendela, pilih + Azure Event Hubs.
Ketik nama untuk pusat aktivitas Anda, dan tentukan jumlah partisi. Karena kami membuat hub peristiwa yang dikompilasi, pilih kebijakan pemadatan sebagai pemadatan dan berikan nilai yang diinginkan untuk waktu retensi batu nisan.
Pilih buat dan buat hub peristiwa yang dikompilasi.

Contoh berikut menunjukkan cara membuat topik pusat aktivitas/Kafka yang dikompilasi menggunakan templat ARM.

"resources": [
  {
    "apiVersion": "2017-04-01",
    "name": "[parameters('eventHubName')]",
    "type": "eventhubs",
    "dependsOn": [
      "[resourceId('Microsoft.EventHub/namespaces/', parameters('eventHubNamespaceName'))]"
    ],
    "properties": {
      "partitionCount": "[parameters('partitionCount')]",
      "retentionDescription": {
        "cleanupPolicy": "compact",
        "tombstoneRetentionTimeInHours": "24"
      }
    }
  }
]

Memicu pemadatan

Layanan Azure Event Hubs menentukan kapan pekerjaan pemadatan dari hub peristiwa ringkas tertentu harus dijalankan. Hub peristiwa yang dikompresi mencapai ambang pemadatan ketika ada sejumlah besar peristiwa atau ukuran total log peristiwa tertentu tumbuh secara signifikan.

Menerbitkan peristiwa ke topik yang dikompilasi

Menerbitkan peristiwa ke pusat aktivitas yang dikompresi sama dengan menerbitkan peristiwa ke pusat aktivitas reguler. Karena aplikasi klien, Anda hanya perlu menentukan kunci pemadatan, yang Anda tetapkan menggunakan kunci partisi.

Menggunakan Event Hubs SDK (AMQP)

Dengan Azure Event Hubs SDK, Anda dapat mengatur kunci partisi dan menerbitkan peristiwa seperti yang ditunjukkan di bawah ini:

var enqueueOptions = new EnqueueEventOptions
{
    PartitionKey = "Key-1"
    
};
await producer.EnqueueEventAsync(eventData, enqueueOptions);

Menggunakan Kafka

Dengan Kafka Anda dapat mengatur kunci partisi saat membuat seperti yang ditunjukkan ProducerRecord di bawah ini:

ProducerRecord<String, String> record = new ProducerRecord<String, String>(TOPIC, "Key-1" , "Value-1");

Kuota dan batasan

Batas	Dasar	Standar	Premium	Khusus
Ukuran hub peristiwa yang dikompresi	T/A	1 GB per partisi	250 GB per partisi	250 GB per partisi

Untuk kuota dan batasan lainnya, lihat Kuota dan batas Azure Event Hubs.

Mengonsumsi peristiwa dari topik yang dikompilasi

Tidak ada perubahan yang diperlukan di sisi konsumen untuk mengonsumsi peristiwa dari hub peristiwa yang dikompresi. Jadi, Anda dapat menggunakan salah satu aplikasi konsumen yang ada untuk mengonsumsi data dari pusat aktivitas yang dikompresi.

Langkah berikutnya

Untuk informasi konseptual tentang cara kerja pemadatan log, lihat Pemadatan log.

Bagikan melalui