Używanie kompaktowania dzienników

W tym artykule pokazano, jak używać funkcji kompaktowania dzienników w usłudze Event Hubs. Aby poznać szczegóły kompaktowania dzienników, zobacz Log Compaction.

W tym artykule wykonaj następujące kluczowe kroki:

• Utwórz zagęszczone centrum zdarzeń/temat platformy Kafka.
• Publikowanie zdarzeń w zagęszczonym centrum zdarzeń.
• Używanie zdarzeń z zagęszczonego centrum zdarzeń.

Uwaga

Funkcja kompaktowania dzienników nie jest obsługiwana w warstwie Podstawowa .

Tworzenie kompaktowanego centrum zdarzeń/tematu platformy Kafka

W tej sekcji pokazano, jak utworzyć kompaktowane centrum zdarzeń przy użyciu Azure Portal i szablonu usługi Azure Resource Manager (ARM).

Witryna Azure Portal

Centrum zdarzeń zwartych można utworzyć przy użyciu Azure Portal, wykonując następujące kroki.

1. Przejdź do przestrzeni nazw usługi Event Hubs.
2. Na stronie przestrzeni nazw usługi Event Hubs wybierz pozycję Event Hubs w menu po lewej stronie.
3. W górnej części okna wybierz pozycję + Event Hubs.
4. Wpisz nazwę centrum zdarzeń i określ liczbę partycji. Ponieważ tworzymy kompaktowane centrum zdarzeń, wybierz zasady kompaktowania jako kompaktowania i podaj żądaną wartość czasu przechowywania nagrobka.
5. Wybierz pozycję Utwórz i utwórz kompaktowane centrum zdarzeń.

Szablon usługi ARM

W poniższym przykładzie pokazano, jak utworzyć kompaktowane centrum zdarzeń/temat platformy Kafka przy użyciu szablonu usługi 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"
      }
    }
  }
]

Wyzwalanie kompaktowania

Usługa Event Hubs określa, kiedy należy wykonać zadanie kompaktowania danego kompaktowanego centrum zdarzeń. Kompaktowane centrum zdarzeń osiąga próg kompaktowania, gdy istnieje znaczna liczba zdarzeń lub całkowity rozmiar danego dziennika zdarzeń znacznie się zwiększa.

Publikowanie zdarzenia w zagęszczonym temacie

Publikowanie zdarzeń w zagęszczonym centrum zdarzeń jest takie samo jak publikowanie zdarzeń w regularnym centrum zdarzeń. Jako aplikacja kliencka musisz określić tylko klucz kompaktowania, który został ustawiony przy użyciu klucza partycji.

Korzystanie z zestawu SDK usługi Event Hubs (AMQP)

Za pomocą zestawu SDK usługi Event Hubs można ustawić klucz partycji i opublikować zdarzenia, jak pokazano poniżej:

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

Korzystanie z platformy Kafka

Za pomocą platformy Kafka można ustawić klucz partycji podczas tworzenia elementu ProducerRecord , jak pokazano poniżej:

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

Limity przydziału i ograniczenia

Limit	Podstawowa	Standardowa (Standard)	Premium	Dedykowane
Rozmiar kompaktowanego centrum zdarzeń	Nie dotyczy	1 GB na partycję	250 GB na partycję	250 GB na partycję

Aby uzyskać inne limity przydziału i limity, zobacz Limity i limity usługi Event Hubs.

Korzystanie z zdarzeń z zagęszczonego tematu

Po stronie konsumenta nie są wymagane żadne zmiany w celu korzystania z zdarzeń z zagęszczonego centrum zdarzeń. W związku z tym możesz użyć dowolnej z istniejących aplikacji konsumenckich do korzystania z danych z zagęszczonego centrum zdarzeń.

Następne kroki

• Aby uzyskać informacje koncepcyjne na temat sposobu działania kompaktacji dzienników, zobacz Kompaktowanie dzienników.