GetAzureEventHub 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Description¶
Reçoit des messages provenant de Microsoft Azure Event Hubs sans suivi fiable des points de contrôle. Dans un environnement en cluster, les instances du processeur GetAzureEventHub fonctionnent indépendamment et tous les nœuds du cluster traitent tous les messages (sauf si le processeur fonctionne en mode primaire uniquement). ConsumeAzureEventHub propose l’approche recommandée pour la réception de messages en provenance d’Azure Event Hubs. Ce processeur crée un pool de threads pour les connexions Azure Event Hubs.
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Event Hub Consumer Group |
Le nom du groupe de consommateurs à utiliser lors de l’extraction d’événements |
Temps de mise en file d’attente des messages du centre d’événements |
Un horodatage (ISO-8601 Instant) formaté sous la forme YYYY-MM-DDThhmmss. sssZ (2016-01-01T01:01:01.000Z) à partir duquel des messages auraient dû être mis en file d’attente dans le Hub d’événements pour commencer à lire les messages |
Nom du centre d’événements |
Nom de la source Azure Event Hubs |
Espace de noms du Hub d’événements |
Espace de noms des Azure Event Hubs préfixé au domaine du point de terminaison du bus de service |
Délai d’expiration du récepteur de partition (millisecondes) |
Durée en millisecondes pendant laquelle un récepteur de partition doit attendre de recevoir la taille de l’extraction avant de revenir. La valeur par défaut est 60000. |
Taille de recherche du récepteur de partition |
Nombre d’événements qu’un récepteur doit aller chercher dans une partition Event Hubs avant de revenir. La valeur par défaut est 100. |
Point de terminaison du bus de service |
Pour prendre en charge les espaces de noms ne faisant pas partie du domaine windows.net par défaut. |
Nom de la politique d’accès partagé |
Nom de la politique d’accès partagé. Cette politique doit être configurée avec Listen claims. |
Clé principale de la politique d’accès partagé |
La clé de la politique d’accès partagé. Il est possible d’utiliser soit la clé primaire, soit la clé secondaire. |
Type de transport |
Type de transport du protocole avancé de mise en file d’attente des messages pour la communication avec les hubs d’événements Azure |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. |
use-managed-identity |
Indique si l’identité gérée d’Azure VM/VMSS sera utilisée ou non |
Relations¶
Nom |
Description |
|---|---|
success |
Tout FlowFile reçu avec succès du centre d’événements sera transféré dans cette relation. |
Écrit les attributs¶
Nom |
Description |
|---|---|
eventhub.enqueued.timestamp |
Heure (en millisecondes depuis l’époque, UTC) à laquelle le message a été mis en file d’attente dans le hub d’événements |
eventhub.offset |
Le décalage au sein de la partition où le message a été stocké |
eventhub.sequence |
Le numéro de séquence Azure associé au message |
eventhub.name |
Le nom du hub d’événements d’où le message a été extrait |
eventhub.partition |
Le nom de la partition du concentrateur d’événements d’où le message a été extrait |
eventhub.property.* |
Les propriétés d’application de ce message. Exemple : « application » correspondrait à « eventhub.property.application » |