GetSQS 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Beschreibung¶
Ruft Meldungen aus einer Amazon Simple Queuing Service-Warteschlange ab
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
AWS-Anmeldeinformationen-Anbieterdienst |
Der Controller Service, der verwendet wird, um AWS-Anmeldeinformationsanbieter zu erhalten |
Auto Delete Messages |
Gibt an, ob die Meldungen von den Prozessoren automatisch gelöscht werden sollen, nachdem sie empfangen wurden. |
Batch Size |
Die maximale Anzahl von Meldungen, die in einer einzigen Netzwerkanfrage gesendet werden können |
Zeichensatz |
Der Zeichensatz, der für die Codierung des Textinhalts der SQS-Meldung verwendet werden soll |
Communications Timeout |
|
Endpoint Override URL |
Endpunkt-URL, die anstelle des AWS Standardwerts verwendet werden soll, einschließlich Schema, Host, Port und Pfad. Die AWS-Bibliotheken wählen eine Endpunkt-URL auf der Grundlage der AWS-Region aus, aber diese Eigenschaft überschreibt die ausgewählten Endpunkt-URL und ermöglicht die Verwendung mit anderen S3-kompatiblen Endpunkten. |
Queue URL |
Die URL der Warteschlange, von der Sie Meldungen erhalten |
Receive Message Wait Time |
Die maximale Wartezeit für einen Long-Polling-Empfangsaufruf. Wenn Sie hier einen Wert von 1 Sekunde oder mehr einstellen, wird die Anzahl der SQS-Anfragen reduziert und die Abruflatenz verringert, allerdings auf Kosten eines ständig aktiven Threads. |
Region |
|
SSL Context Service |
Gibt einen optionalen SSL Context Service an, der, falls vorhanden, zum Erstellen von Verbindungen verwendet wird |
Visibility Timeout |
Die Zeitspanne, nach der eine Meldung , die empfangen, aber nicht gelöscht wurde, für andere Verbraucher verborgen bleibt. |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
FlowFiles werden an die Beziehung „success“ weitergeleitet |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
hash.value |
Die MD5-Summe der Meldungen |
hash.algorithm |
MD5 |
sqs.message.id |
Der eindeutige Bezeichner der SQS-Meldung |
sqs.receipt.handle |
Der SQS Receipt Handle, der zum Löschen der Meldung aus der Warteschlange verwendet werden soll. |