Démarrage rapide : Envoyer et recevoir des messages volumineux avec Azure Event Hubs (préversion)
Dans ce guide de démarrage rapide, vous apprenez à envoyer et recevoir des messages volumineux (jusqu’à 20 Mo) en utilisant Azure Event Hubs. Si vous débutez avec Event Hubs, consultez la Vue d’ensemble Event Hubs avant de suivre ce guide de démarrage rapide.
Prérequis
Pour effectuer ce démarrage rapide, vous avez besoin de ce qui suit :
- Un abonnement Azure. Pour utiliser les services Azure, y compris Event Hubs, il vous faut un abonnement. Si vous n’avez pas de compte Azure, vous pouvez vous inscrire à un essai gratuit ou utiliser les avantages de votre abonnement MSDN quand vous créez un compte.
- Créez un cluster dédié évolutif en libre-service, un espace de noms Event Hubs et un Event Hub. La première étape pour répondre à cette condition préalable consiste à utiliser le Portail Azure pour créer un cluster dédié et un espace de noms dans un cluster. Pour créer un hub d’événements, consultez Démarrage rapide : Créer un Event Hub en utilisant le Portail Azure. Vous pouvez ignorer cette étape si vous disposez déjà d’un cluster dédié évolutif en libre-service.
Remarque
La prise en charge des messages volumineux (actuellement en préversion publique) est exclusivement disponible avec certains clusters dédiés en libre-service d’Event Hubs. Le streaming de messages volumineux avec ces clusters n’entraîne aucun frais supplémentaire.
Créer un cluster dédié Event Hubs
Pour streamer des messages volumineux, vous devez configurer votre cluster dédié évolutif en libre-service.
Dans le Portail Azure, accédez à la section Paramètres du cluster dédié. Sous Paramètres, sélectionnez l’onglet Quota.
- Vérifiez que la valeur de la clé
supportslargemessages
en lecture seule est définie surTrue
. - Vous pouvez mettre à jour la clé
eventhubmaxmessagesizeinbytes
sur une valeur en octets appropriée. La plage acceptable pour cette valeur est comprise entre 1 048 576 et 20 971 520 octets.
Une fois la configuration enregistrée, vous êtes prêt à diffuser en continu des messages volumineux avec Event Hubs.
Important
La diffusion en continu de messages volumineux est uniquement prise en charge avec des clusters dédiés évolutifs en libre-service créés à partir de l’infrastructure la plus récente. Cette fonctionnalité est reflétée par la clé Supportslargemessages
.
Si la valeur d’un cluster est fausse, le cluster ne prend pas en charge la diffusion en continu de messages volumineux. Pour activer cette fonctionnalité, vous devez recréer le cluster.
Diffuser en continu des messages volumineux avec Event Hubs
Event Hubs permet de diffuser en continu des messages volumineux de jusqu’à 20 Mo, à la fois en tant que lots et en tant que publications individuelles. La capacité de diffuser en continu des messages volumineux ou des événements ne nécessite aucune modification du code client, à l’exception de la modification du message ou de l’événement lui-même. Vous pouvez continuer à envoyer/recevoir des messages à l’aide de n’importe quel Kit de développement logiciel (SDK) Event Hubs ou n’importe quelle API Kafka existante pour diffuser en continu des messages volumineux vers Event Hubs. Cela vous permet de diffuser en continu des messages volumineux vers Event Hubs de la même manière que vous le feriez pour les messages de taille inférieure à 1 Mo.
Pour plus d’informations, consultez Envoyer des événements vers et recevez des événements à partir d’Event Hubs avec .NET.
Conseil
Veillez à bien passer en revue tout client Advance Message Queueing Protocol (AMQP) d’Event Hubs, ou la configuration du client Kafka, qui pourrait limiter la taille maximale des messages que vous diffusez vers Event Hubs. Vous devez mettre à jour le délai d’expiration du client sur une valeur plus élevée pour diffuser en continu des messages volumineux.
Par défaut, le nombre de prérécupérations du client AMQP est de 300. Réduisez cette valeur pour éviter des problèmes de mémoire côté client lorsque vous gérez des messages volumineux.
Pour voir la référence complète de la bibliothèque .NET, consultez la Documentation du SDK.