PublishAMQP 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-amqp-nar

Description¶

Crée un message AMQP à partir du contenu d’un FlowFile et envoie le message à un échange AMQP. Dans un modèle d’échange AMQP typique, le message envoyé à l’Exchange AMQP sera routé en fonction de la “Routing Key” vers sa destination finale dans la file d’attente (le lien). Si, en raison d’une mauvaise configuration, le lien entre l’Exchange, la Routing Key et la file d’attente n’est pas établi, le message n’aura pas de destination finale et sera renvoyé (c’est-à-dire que les données n’atteindront pas la file d’attente). Si cela se produit, un journal sera enregistré à la fois dans app-log et bulletin pour indiquer ce fait, et le FlowFile sera routé vers la relation “failure”.

Balises¶

amqp, message, publish, put, rabbit, send

Exigences en matière d’entrées¶

REQUIRED

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.
Exchange Name	Le nom de l’échange AMQP auquel les messages seront envoyés. Généralement fourni par l’administrateur de AMQP (par exemple, “amq.direct”). Il s’agit d’une propriété facultative. Si elle est laissée vide, les messages seront envoyés à un Exchange AMQP par défaut.
Headers Pattern	Expression régulière évaluée par rapport aux attributs FlowFile afin de sélectionner les attributs correspondants et de les placer comme en-têtes AMQP. Le nom de l’attribut sera utilisé comme clé d’en-tête.
Headers Source	La source des en-têtes qui seront appliqués au message publié.
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.
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.
Routing Key	Nom de la Routing Key qui sera utilisé par AMQP pour router les messages de l’Exchange vers une ou plusieurs files de destination. Lorsqu’un message est envoyé à un Exchange par défaut, cette propriété correspond au nom de la file de destination ; sinon, un lien entre l’Exchange et une file via la Routing Key doit être configuré (généralement 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.
header.separator	Le caractère utilisé pour fractionner clé-valeur dans les en-têtes. La valeur ne doit comporter qu’un seul caractère. Dans le cas contraire, vous obtiendrez un message d’erreur

Relations¶

Nom	Description
failure	Tous les FlowFiles qui ne peuvent pas être routés vers la destination AMQP sont routés vers cette relation.
success	Tous les FlowFiles qui sont envoyés à la destination AMQP sont routés vers cette relation.