FetchS3Object 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Beschreibung¶
Ruft den Inhalt eines S3-Objekts ab und schreibt ihn in den Inhalt eines FlowFile
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
AWS-Anmeldeinformationen-Anbieterdienst |
Der Controller Service, der verwendet wird, um AWS-Anmeldeinformationsanbieter zu erhalten |
Bucket |
Der S3-Bucket, mit dem interagiert werden soll |
Communications Timeout |
Die Zeitspanne, die gewartet wird, um eine Verbindung zu AWS herzustellen oder Daten von AWS zu empfangen, bevor es zu einem Timeout kommt. |
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. |
Object Key |
Der zu verwendende S3-Objektschlüssel. Dies entspricht einem Dateinamen in herkömmlichen Dateisystemen. |
Region |
Die AWS-Region, mit der Sie sich verbinden möchten. |
SSL Context Service |
Gibt einen optionalen SSL Context Service an, der, falls vorhanden, zum Erstellen von Verbindungen verwendet wird |
Signer Override |
Die AWS-S3-Bibliothek verwendet standardmäßig die Signaturversion 4, aber mit dieser Eigenschaft können Sie den Signierer der Version 2 angeben, um ältere S3-kompatible Dienste zu unterstützen oder sogar Ihre eigene benutzerdefinierte Signierer-Implementierung einzubinden. |
Version |
Die Version des Objekts zum Herunterladen |
custom-signer-class-name |
Vollständig qualifizierter Klassenname der benutzerdefinierten Signaturklasse. Der Signierer muss die Schnittstelle „com.amazonaws.auth.Signer“ implementieren. |
custom-signer-module-location |
Durch Kommas getrennte Liste von Pfaden zu Dateien und/oder Verzeichnissen, die die JAR-Datei des benutzerdefinierten Signierers und deren Abhängigkeiten (falls vorhanden) enthalten. |
encryption-service |
Gibt den Verschlüsselungsdienst-Controller an, der zur Konfiguration von Anfragen verwendet wird. PutS3Object: Aus Gründen der Abwärtskompatibilität wird dieser Wert ignoriert, wenn „Server Side Encryption“ eingestellt ist. FetchS3Object: Muss nur bei serverseitiger Kundenschlüssel-, clientseitiger KMS- und clientseitiger Kundenschlüsselverschlüsselung konfiguriert werden. |
proxy-configuration-service |
Gibt den Proxy-Konfigurations-Controller Service an für die Weiterleitung von Netzwerkanforderungen festl. |
range-length |
Die Anzahl der Bytes, die vom Objekt heruntergeladen werden sollen, beginnend mit dem „Range Start“. Ein leerer Wert oder ein Wert, der über das Ende des Objekts hinausgeht, wird bis zum Ende des Objekts gelesen. |
range-start |
Die Byte-Position, an der das Lesen aus dem Objekt beginnen soll. Bei einem leeren Wert oder einem Wert von Null beginnt das Lesen am Anfang des Objekts. |
requester-pays |
Bei „true“ bedeutet dies, dass der Anfragende zustimmt, alle mit dem Abruf von Objekten aus dem S3-Bucket verbundenen Gebühren zu zahlen. Dies setzt den Header „x-amz-request-payer“ auf „requester“. |
Beziehungen¶
Name |
Beschreibung |
|---|---|
failure |
Wenn der Prozessor nicht in der Lage ist, ein bestimmtes FlowFile zu verarbeiten, wird es an diese Beziehung weitergeleitet. |
success |
FlowFiles werden nach erfolgreicher Bearbeitung an diese Beziehung weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
s3.url |
Die URL, die für den Zugriff auf das S3-Objekt verwendet werden kann |
s3.bucket |
Der Name des S3-Buckets |
Pfad |
Der Pfad der Datei |
absolute.path |
Der Pfad der Datei |
filename |
Der Name der Datei |
hash.value |
Die MD5-Summe der Datei |
hash.algorithm |
MD5 |
mime.type |
Wenn S3 den Inhaltstyp/MIME-Typ bereitstellt, enthält dieses Attribut diese Datei. |
s3.etag |
Das ETag, das verwendet werden kann, um zu sehen, ob sich die Datei geändert hat |
s3.exception |
Der Klassenname der Ausnahme, die während der Ausführung des Prozessors ausgelöst wird |
s3.additionalDetails |
Die von S3 gelieferten Details der fehlgeschlagenen Operation |
s3.statusCode |
Der HTTP-Fehlercode (falls verfügbar) der fehlgeschlagenen Operation |
s3.errorCode |
Der S3-Bezeichner der fehlgeschlagenen Operation |
s3.errorMessage |
Die S3-Ausnahmemeldung der fehlgeschlagenen Operation |
s3.expirationTime |
Wenn die Datei ein Verfallsdatum hat, wird dieses Attribut gesetzt, das die Millisekunden seit Epoche in UTC-Zeit enthält. |
s3.expirationTimeRuleId |
Die ID der Regel, die die Ablaufzeit dieses Objekts vorgibt |
s3.sseAlgorithmus |
Der serverseitige Verschlüsselungsalgorithmus des Objekts |
s3.version |
Die Version des S3-Objekts |
s3.encryptionStrategy |
Der Name der Verschlüsselungsstrategie, die zum Speichern des S3-Objekts verwendet wurde (falls es verschlüsselt ist) |
Anwendungsfälle¶
Abrufen einer bestimmte Datei aus S3 |
Anwendungsfälle mit anderen Komponenten¶
Abrufen aller Dateien in einem S3-Bucket |
Nur Dateien aus S3 abrufen, die bestimmte Kriterien erfüllen |
Neue Dateien abrufen, sobald sie in einem S3-Bucket eintreffen. |