GetAzureQueueStorage_v12 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Beschreibung¶
Ruft die Meldungen aus einem Azure-Warteschlangenspeicher ab. Die abgerufenen Meldungen werden standardmäßig aus der Warteschlange gelöscht. Wenn die Anforderung lautet, Meldungen zu verarbeiten, ohne sie zu löschen, setzen Sie „Auto Delete Messages“ auf „false“. Hinweis: Es kann vorkommen, dass Sie Duplikate erhalten, z. B. wenn eine Meldung empfangen wurde, diese aber aufgrund unerwarteter Umstände nicht aus der Warteschlange gelöscht werden konnte.
Eingabeanforderung¶
FORBIDDEN
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Auto Delete Messages |
Gibt an, ob die empfangene Meldung automatisch aus der Warteschlange gelöscht werden soll. |
Credentials Service |
Controller Service, der verwendet wird, um Azure Storage-Anmeldeinformationen zu erhalten. |
Message Batch Size |
Die Anzahl der Meldungen, die aus der Warteschlange abgerufen werden sollen. |
Queue Name |
Name of the Azure Storage Queue |
Request Timeout |
Das Timeout für Lese- oder Schreibanfragen an Azure Queue Storage. Der Standardwert ist 1 Sekunde. |
Visibility Timeout |
Die Dauer, während der die abgerufene Meldung für andere Verbraucher unsichtbar sein soll. |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. Im Falle von SOCKS ist nicht garantiert, dass die ausgewählte SOCKS-Version vom Prozessor verwendet wird. |
storage-endpoint-suffix |
Speicherkonten im öffentlichen Azure verwenden immer ein gemeinsames FQDN-Suffix. Überschreiben Sie dieses Endpunkt-Suffix unter bestimmten Umständen (z. B. Azure Stack oder nicht öffentliche Azure-Regionen) durch ein anderes Suffix. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
success |
Alle erfolgreich bearbeiteten FlowFiles werden an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
azure.queue.uri |
Die absolute URI des konfigurierten Azure Queue Storage |
azure.queue.insertionTime |
Der Zeitpunkt, zu dem die Meldung in den Warteschlangenspeicher eingefügt wurde |
azure.queue.expirationTime |
Der Zeitpunkt, an dem die Meldung aus dem Warteschlangenspeicher abläuft |
azure.queue.messageId |
Die ID der abgerufenen Meldung |
azure.queue.popReceipt |
Die Empfangsbestätigung der abgerufenen Meldung |