Utiliser le compactage des journaux

Article
08/02/2023

Cet article vous explique comment utiliser la fonctionnalité de compactage des journaux dans Event Hubs. Pour comprendre les détails du compactage des journaux, consultez Compactage des journaux.

Dans cet article, vous allez suivre les étapes clés suivantes :

Créez une rubrique Event Hub/Kafka compactée.
Publier des événements dans un hub d’événements compacté.
Consommer des événements à partir d’un hub d’événements compacté.

Notes

La fonctionnalité de compactage du journal n’est pas prise en charge dans le niveau De base.

Créez une rubrique Event Hub/Kafka compactée

Cette section vous montre comment créer un hub d’événements compacté à l’aide de Portail Azure et d’un modèle Azure Resource Manager (ARM).

Azure portal
Modèle ARM

Vous pouvez créer un hub d’événements compacté à l’aide du Portail Azure en suivant ces étapes.

Accédez à votre espace de noms Event Hubs.
Dans la page Espace de noms Event Hubs, sélectionnez Event Hubs dans le menu de gauche.
En haut de la fenêtre, sélectionnez + Event Hubs.
Tapez un nom pour votre hub d’événements et spécifiez le nombre de partitions. Étant donné que nous créons un hub d’événements compacté, sélectionnez stratégie de compactage comme compactage et fournissez la valeur souhaitée pour le temps de rétention objet tombstone.
Sélectionnez Créer et créer le hub d’événements compacté.

L’exemple suivant montre comment créer une rubrique Event Hub/Kafka compactée à l’aide d’un modèle 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"
      }
    }
  }
]

Déclenchement du compactage

Le service Event Hubs détermine quand le travail de compactage d’un hub d’événements compacté donné doit être exécuté. Le hub d’événements compacté atteint le seuil de compactage lorsqu’il existe un nombre important d’événements ou que la taille totale d’un journal des événements donné augmente considérablement.

Publier un événement dans une rubrique compactée

La publication d’événements dans un hub d’événements compacté est identique à la publication d’événements dans un hub d’événements standard. En tant qu’application cliente, il vous suffit de déterminer la clé de compactage, que vous définissez à l’aide de la clé de partition.

Utilisation du Kit de développement logiciel (SDK) Event Hubs (AMQP)

Avec le Kit de développement logiciel (SDK) Event Hubs, vous pouvez définir la clé de partition et publier des événements comme indiqué ci-dessous :

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

Utilisation de Kafka

Avec Kafka, vous pouvez définir la clé de partition lorsque vous créez le ProducerRecord comme indiqué ci-dessous :

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

Quotas et limites

Limite	De base	Standard	Premium	Dédié
Taille du hub d’événements compacté	N/A	1 Go par partition	250 Go par partition	250 Go par partition

Pour d’autres quotas et limites, consultez Quotas et limites de Azure Event Hubs.

Consommation d’événements à partir d’une rubrique compactée

Aucune modification n’est requise côté consommateur pour consommer des événements à partir d’un hub d’événements compacté. Ainsi, vous pouvez utiliser n’importe quelle application consommateur existante pour consommer des données à partir d’un hub d’événements compacté.

Étapes suivantes

Pour plus d’informations conceptuelles sur le fonctionnement du compactage des journaux, consultez Compactage des journaux.

Partager via