ListenUDPRecord 2025.10.9.21¶
Bundle¶
org.apache.nifi | nifi-standard-nar
Beschreibung¶
Listen Sie den Inhalt eines jeden Datendiagramms mit dem konfigurierten Record Reader auf. Jeder Datensatz wird dann mit dem konfigurierten Record Writer in ein Flowfile geschrieben. Dieser Prozessor kann darauf beschränkt werden, Datagramme von einem bestimmten Remote-Host und Port zu überwachen, indem Sie die Eigenschaften „Sending Host“ und „Sending Host Port“ angeben. Andernfalls wird auf Datagramme von allen Hosts und Ports überwacht.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Zeichensatz |
Gibt den Zeichensatz der empfangenen Daten an. |
Local Network Interface |
Der Name einer lokalen Netzwerkschnittstelle, die verwendet werden soll, um das Abhören auf ein bestimmtes LAN zu beschränken. |
Max Size of Message Queue |
Die maximale Größe der internen Warteschlange, die zum Puffern von Meldungen verwendet wird, die vom zugrunde liegenden Kanal zum Prozessor übertragen werden. Wenn dieser Wert höher eingestellt ist, können bei einem Anstieg der eingehenden Meldungen mehr Meldungen im Speicher gepuffert werden, aber der vom Prozessor insgesamt belegte Speicher wird größer. |
Max Size of Socket Buffer |
Die maximale Größe des Socket-Puffers, der verwendet werden soll. Dies ist ein Vorschlag an das Betriebssystem, wie groß der Socket-Puffer sein soll. Wenn dieser Wert zu niedrig eingestellt ist, kann der Puffer voll werden, bevor die Daten gelesen werden können, und eingehende Daten gehen verloren. |
Port |
Der Port, der für die Kommunikation überwacht werden soll. |
Receive Buffer Size |
Die Größe der einzelnen Puffer, die für den Empfang von Meldungen verwendet werden. Passen Sie diesen Wert entsprechend der erwarteten Größe der eingehenden Meldungen an. |
batch-size |
Die maximale Anzahl von Datagrammen, die als Datensätze in ein einzelnes FlowFile geschrieben werden. Die Batchgröße wird nur erreicht, wenn die Daten häufiger eintreffen als die Abfragezeit. |
poll-timeout |
Die Zeit, die gewartet wird, wenn die interne Warteschlange nach weiteren Datagrammen abgefragt wird. Wenn nach Ablauf des konfigurierten Timeouts keine Datagramme gefunden werden, gibt der Prozessor alle bis zu diesem Zeitpunkt empfangenen Datensätze aus. |
record-reader |
Der Record Reader, der zum Lesen des Inhalts eingehender Datagramme verwendet wird. |
record-writer |
Der Record Writer, der verwendet werden soll, um die Daten vor dem Schreiben in ein FlowFile zu serialisieren. |
sending-host |
IP oder Name eines entfernten Hosts. Es werden nur Datagramme von dem angegebenen Port des sendenden Hosts und diesem Host akzeptiert. Verbessert die Leistung. Kann eine Systemeigenschaft oder eine Umgebungsvariable sein. |
sending-host-port |
Port, der vom entfernten Host zum Senden von Datagrammen verwendet wird. Es werden nur Datagramme von dem angegebenen sendenden Host und diesem Port akzeptiert. Verbessert die Leistung. Kann eine Systemeigenschaft oder eine Umgebungsvariable sein. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
parse.failure |
Wenn ein Datagramm nicht mit dem konfigurierten Record Reader geparst werden kann, wird der Inhalt der Meldung an diese Relation als eigenes FlowFile weitergeleitet. |
success |
Erfolgreich empfangene Meldungen werden über diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
udp.sender |
Der sendende Host der Meldungen. |
udp.port |
Der sendende Port, über den die Meldungen empfangen wurden. |
record.count |
Die Anzahl der Datensätze, die in das FlowFile geschrieben wurden. |
mime.type |
Der Mime-Typ des Writers, der verwendet wird, um die Datensätze in das FlowFile zu schreiben. |