ConsumeAMQP 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-amqp-nar
Description¶
Consomme les messages AMQP provenant d’un broker AMQP utilisant le protocole AMQP 0.9.1. Chaque message reçu du broker AMQP sera émis comme un fichier FlowFile distinct vers la relation « success ».
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Version AMQP |
AMQP Version. Seul AMQP v0.9.1 est actuellement pris en charge. |
Brokers |
La liste séparée par des virgules des brokers AMQP connus, au format <hôte>:<port> (par exemple, localhost:5672). Si cette propriété est définie, les champs Host Name et Port sont ignorés. N’incluez que des hôtes appartenant à un même cluster AMQP. |
Client Certificate Authentication Enabled |
L’authentification se fait à l’aide du certificat SSL plutôt que par nom d’utilisateur/mot de passe. |
Host Name |
Adresse réseau du broker AMQP (par exemple, localhost). Si le paramètre Brokers est défini, cette propriété est ignorée. |
Max Inbound Message Body Size |
Taille maximale du corps des messages entrants (reçus). |
Mot de passe |
Mot de passe utilisé pour l’authentification et l’autorisation. |
Port |
Valeur numérique identifiant le port du broker AMQP (par exemple, 5671). Si le paramètre Brokers est défini, cette propriété est ignorée. |
Queue |
Le nom de la file d’attente AMQP existante à partir de laquelle les messages seront consommés. Généralement prédéfini par l’administrateur AMQP. |
Service contextuel SSL |
Le service de contexte SSL utilisé pour fournir des informations sur les certificats des clients pour les connexions TLS/SSL. |
NomUtilisateur |
Nom d’utilisateur utilisé pour l’authentification et l’autorisation. |
Virtual Host |
Nom d’hôte virtuel qui isole le système AMQP pour une sécurité améliorée. |
auto.acknowledge |
Si cette propriété est définie sur false (Non-Auto-Acknowledge), les messages seront acquittés par le processeur après le transfert des FlowFiles vers la relation « success » et la validation de la session NiFi. Le mode Non-Auto-Acknowledge fournit une sémantique de livraison « au moins une fois ». Si cette propriété est définie sur true (Auto-Acknowledge), les messages qui sont délivrés au client AMQP seront auto-acquittés par le broker AMQP juste après leur envoi. Cela permet généralement d’obtenir un meilleur débit, mais les messages sont perdus en cas de redémarrage ou de panne du broker AMQP, de NiFi ou du processeur. Le mode Auto-Acknowledge fournit une sémantique de livraison « au plus une fois » et n’est recommandé que si la perte de messages est acceptable. |
batch.size |
Le nombre maximum de messages qui doivent être traités dans une seule session. Une fois que ce nombre de messages a été reçu (ou qu’il n’y a plus de messages disponibles), les messages reçus sont transférés à la relation « success » et un accusé de réception est envoyé au broker AMQP. Une valeur plus élevée pourrait améliorer les performances, en particulier pour les très petits messages, mais risque également d’entraîner la duplication d’un plus grand nombre de messages lors d’un redémarrage soudain de NiFi. |
header.format |
Définit comment sortir les en-têtes du message reçu |
header.key.prefix |
Texte à préfixer aux clés d’en-tête lorsque celles-ci sont ajoutées aux attributs du FlowFile. Le processeur ajoutera « . » à la valeur de cette propriété |
header.separator |
Le caractère utilisé pour séparer la clé et la valeur d’un en-tête sous forme de chaîne de caractères. La valeur ne doit comporter qu’un seul caractère. |
prefetch.count |
Nombre maximal de messages non acquittés pour le consommateur. Si le consommateur a ce nombre de messages non acquittés, le broker AMQP n’enverra plus de nouveaux messages jusqu’à ce que le consommateur acquitte certains des messages qui lui ont déjà été livrés. Valeurs autorisées : de 0 à 65535. 0 signifie aucune limite |
remove.curly.braces |
Si cette propriété est définie sur true, les accolades figurant dans l’en-tête seront automatiquement supprimées. |
Relations¶
Nom |
Description |
|---|---|
success |
Tous les FlowFiles reçus de la file d’attente AMQP sont routés vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
amqp$appId |
Le champ App ID du message AMQP |
amqp$contentEncoding |
Le codage du contenu signalé par le message AMQP |
amqp$contentType |
Le type de contenu signalé par le message AMQP |
amqp$headers |
Les en-têtes présents dans le message AMQP. Ajoutés uniquement si le processeur est configuré pour produire cet attribut. |
<Préfixe de clé d’en-tête>.<attribut> |
Chaque en-tête de message sera inséré avec ce nom d’attribut, à condition que le processeur soit configuré pour générer les en-têtes sous la forme d’un attribut |
amqp$deliveryMode |
Indicateur numérique du mode d’acheminement du message |
amqp$priority |
La priorité du message |
amqp$correlationId |
L’ID de corrélation du message |
amqp$replyTo |
La valeur du champ Reply-To du message |
amqp$expiration |
L’expiration du message |
amqp$messageId |
L’ID unique du message |
amqp$timestamp |
L’horodatage du message, en nombre de millisecondes depuis l’époque |
amqp$type |
Le type du message |
amqp$userId |
L’ID de l’utilisateur |
amqp$clusterId |
L’ID du cluster AMQP |
amqp$routingKey |
La clé de routage du message AMQP |
amqp$exchange |
L’exchange à partir duquel le message AMQP a été reçu |