ConsumeAMQP 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-amqp-nar
Beschreibung¶
Verarbeitet AMQP-Meldungen von einem AMQP-Broker über das AMQP-Protokoll 0.9.1. Jede Meldung, die vom AMQP-Broker empfangen wird, wird als eigenes FlowFile an die Beziehung „success“ gesendet.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
AMQP-Version |
AMQP Version. Unterstützt derzeit nur AMQP v0.9.1. |
Auto-Acknowledge Messages |
Bei „false“ (Non-Auto-Acknowledge), werden die Meldungen vom Prozessor bestätigt, nachdem die FlowFiles an „success“ übertragen und die NiFi-Sitzung abgeschlossen wurde. Der Modus „Nicht-Auto-Acknowledge“ bietet eine Zustellsemantik nach dem Prinzip „mindestens-einmal“. Bei „true“ (Auto-Acknowledge) werden Meldungen, die an den AMQP-Client geliefert werden, vom AMQP-Broker direkt nach demS enden automatisch bestätigt. Dies führt in der Regel zu einem besseren Durchsatz, kann jedoch auch dazu führen, dass Meldungen bei einem Neustart/Absturz des AMQP-Brokers, von NiFi oder des Prozessors verloren gehen. Der Modus „Auto-Acknowledge“ bietet eine Zustellsemantik nach dem Prinzip „höchstens einmal“ und wird nur empfohlen, wenn der Verlust von Meldungen akzeptabel ist. |
Batch Size |
Die maximale Anzahl von Meldungen, die in einer einzigen Sitzung verarbeitet werden sollen. Sobald diese Anzahl an Meldungen empfangen wurde (oder sobald keine weiteren Meldungen mehr verfügbar sind), werden die empfangenen Meldungen an die Beziehung „success“ übertragen und beim AMQP-Broker bestätigt. Wenn Sie diesen Wert auf eine größere Zahl setzen, kann dies zu einer besseren Leistung führen, insbesondere bei sehr kleinen Meldungen, aber auch dazu, dass bei einem plötzlichen Neustart von NiFi mehr Meldungen dupliziert werden. |
Brokers |
Eine durch Kommas getrennte Liste der bekannten AMQP-Broker im Format <host>:<port> (z. B. localhost:5672). Bei dieser Einstellung werden Hostname und Port ignoriert. Nur Hosts aus demselben AMQP-Cluster einbeziehen. |
Client Certificate Authentication Enabled |
Authentifiziereung mit dem SSL-Zertifikat anstelle von Benutzername/Kennwort. |
Header Key Prefix |
Text, der den Header-Schlüsseln vorangestellt wird, wenn sie zu den FlowFile-Attributen hinzugefügt werden. Der Prozessor fügt „.“ an den Wert dieser Eigenschaft an |
Header Output Format |
Legt fest, wie die Header der empfangenen Meldung ausgegeben werden sollen |
Header Separator |
Das Zeichen, das verwendet wird, um Schlüssel und Wert in einer Header-Zeichenfolge zu trennen. Der Wert darf nur aus einem Zeichen bestehen. |
Hostname |
Netzwerkadresse des AMQP-Brokers (z. B. localhost). Wenn „Brokers“ eingestellt ist, wird diese Eigenschaft ignoriert. |
Max Inbound Message Body Size |
Maximale Body-Größe bei eingehenden (empfangenen) Meldungen. |
Password |
Kennwort, das für die Authentifizierung und Autorisierung verwendet wird. |
Port |
Numerischer Wert, der den Port des AMQP-Brokers identifiziert (z. B. 5671). Wenn „Brokers“ eingestellt ist, wird diese Eigenschaft ignoriert. |
Prefetch Count |
Die maximale Anzahl von nicht bestätigten Meldungen für den Verbraucher. Wenn der Verbraucher diese Anzahl von nicht bestätigten Meldungen hat, sendet der AMQP-Broker erst dann weitere neue Meldungen, wenn der Verbraucher einige der bereits an ihn übermittelten Meldungen bestätigt. Zulässige Werte: von 0 bis 65.535; 0 bedeutet keine Begrenzung |
Queue |
Der Name der bestehenden AMQP-Warteschlange, aus der Meldungen empfangen werden sollen. In der Regel vom AMQP-Administrator vordefiniert. |
Remove Curly Braces |
Wenn „Remove Curly Braces“ auf „true“ gesetzt ist, werden geschweifte Klammern im Header automatisch entfernt. |
SSL Context Service |
Der SSL Context Service wird verwendet, um Client-Zertifikatsinformationen für TLS/SSL-Verbindungen bereitzustellen. |
Username |
Für die Authentifizierung und Autorisierung verwendeter Benutzername. |
Virtual Host |
Virtueller Hostname, der das AMQP-System für mehr Sicherheit segmentiert. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
Alle FlowFiles, die von der AMQP-Warteschlange empfangen werden, werden an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
amqp$appId |
Das Feld „App ID“ aus der AMQP-Meldung |
amqp$contentEncoding |
Die von der AMQP-Meldung gemeldete Inhaltscodierung |
amqp$contentType |
Der von der AMQP-Meldung gemeldete Inhaltstyp |
amqp$headers |
Die in der AMQP-Meldung vorhandenen Header. Wird nur hinzugefügt, wenn der Prozessor für die Ausgabe dieses Attributs konfiguriert ist. |
<Header Key Prefix>.<attribute> |
Jeder Meldungs-Header wird mit diesem Attributnamen eingefügt, wenn der Prozessor so konfiguriert ist, dass er Header als Attribut ausgibt. |
amqp$deliveryMode |
Der numerische Indikator für den Zustellungsmodus der Meldung |
amqp$priority |
Die Priorität der Meldung |
amqp$correlationId |
Die Korrelations-ID der Meldung |
amqp$replyTo |
Der Wert des Feldes „Reply-To“ der Meldung |
amqp$expiration |
Die Ablaufzeit von Meldungen |
amqp$messageId |
Die eindeutige ID der Meldung |
amqp$timestamp |
Der Zeitstempel der Meldung, als Anzahl der Millisekunden seit Epoche |
amqp$type |
Die Art der Meldung |
amqp$userId |
Die ID des Benutzers |
amqp$clusterId |
Die ID des AMQP-Clusters |
amqp$routingKey |
Der routingKey der AMQP-Meldung |
amqp$exchange |
Die Exchange (Austauschpunkt), von der die AMQP-Meldung empfangen wurde |