ListenUDPRecord 2025.10.9.21¶

Bundle¶

org.apache.nifi | nifi-standard-nar

Description¶

Écoute les datagrammes sur un port donné et lit le contenu de chaque datagramme à l’aide du lecteur d’enregistrement configuré. Chaque enregistrement sera ensuite écrit dans un fichier de flux à l’aide du générateur d’enregistrements configuré. Ce processeur peut être restreint à l’écoute des datagrammes d’un hôte et d’un port distants spécifiques en spécifiant les propriétés Hôte d’envoi et Port de l’hôte d’envoi, sinon il écoutera les datagrammes de tous les hôtes et ports.

Balises¶

ingest, listen, record, source, udp

Exigences en matière d’entrées¶

FORBIDDEN

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Jeu de caractères	Spécifie le jeu de caractères des données reçues.
Interface du réseau local	Le nom d’une interface de réseau local à utiliser pour restreindre l’écoute à un LAN spécifique.
Taille maximale de la file d’attente des messages	Taille maximale de la file d’attente interne utilisée pour mettre en mémoire tampon les messages transférés du canal sous-jacent au processeur. Un paramètre plus élevé permet de mettre en mémoire tampon un plus grand nombre de messages en cas d’afflux de messages entrants, mais augmente la mémoire totale utilisée par le processeur.
Taille maximale de la mémoire tampon du socket	La taille maximale de la mémoire tampon de la socket qui doit être utilisée. Il s’agit d’une suggestion au système d’exploitation pour indiquer la taille de la mémoire tampon de la socket. Si cette valeur est trop faible, la mémoire tampon risque de se remplir avant que les données puissent être lues, et les données entrantes seront abandonnées.
Port	Le port sur lequel la communication doit être écoutée.
Taille du tampon de réception	La taille de chaque tampon utilisé pour recevoir des messages. Ajustez cette valeur de manière appropriée en fonction de la taille prévue des messages entrants.
batch-size	Nombre maximal de datagrammes à écrire en tant qu’enregistrements sur un seul FlowFile. La taille du lot ne sera atteinte que si les données arrivent plus fréquemment que le délai d’expiration.
poll-timeout	Temps d’attente lors de l’interrogation de la file d’attente interne pour d’autres datagrammes. Si aucun datagramme n’est trouvé après le délai d’expiration configuré, le processeur émet les enregistrements obtenus jusqu’alors.
record-reader	Le Record Reader à utiliser pour lire le contenu des datagrammes entrants.
record-writer	Le Record Writer à utiliser pour sérialiser les données avant de les écrire dans un FlowFile.
sending-host	L’adresse IP ou le nom d’un hôte distant. Seuls les datagrammes provenant du port de l’hôte émetteur spécifié et de cet hôte seront acceptés. Améliore les performances. Il peut s’agir d’une propriété du système ou d’une variable d’environnement.
sending-host-port	Port utilisé par l’hôte distant pour envoyer des datagrammes. Seuls les datagrammes provenant de l’hôte émetteur spécifié et de ce port seront acceptés. Améliore les performances. Il peut s’agir d’une propriété du système ou d’une variable d’environnement.

Relations¶

Nom	Description
parse.failure	Si un datagramme ne peut pas être analysé par le Record Reader configuré, le contenu du message sera routé vers cette relation en tant que FlowFile.
success	Les messages reçus avec succès seront envoyés à cette relation.

Écrit les attributs¶

Nom	Description
udp.sender	L’hôte émetteur des messages.
udp.port	Le port émetteur où les messages ont été reçus.
record.count	Le nombre d’enregistrements écrits dans le FlowFile.
mime.type	Le mime-type du Writer utilisé pour écrire les enregistrements dans le FlowFile.