FetchS3Object 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-aws-nar
Description¶
Récupère le contenu d’un objet S3 et l’écrit dans le contenu d’un FlowFile
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Service des fournisseurs d’identifiants de connexion AWS |
Le Controller Service qui est utilisé pour obtenir le fournisseur d’identifiants de connexion AWS |
Compartiment |
Le compartiment S3 avec lequel interagir |
Délai d’expiration de la communication |
Le temps d’attente pour établir une connexion avec AWS ou recevoir des données de AWS avant qu’un délai d’expiration ne se produise. |
Endpoint Override URL |
URL du point de terminaison à utiliser à la place du point de terminaison AWS par défaut, y compris le schéma, l’hôte, le port et le chemin. Les bibliothèques AWS sélectionnent une URL de point de terminaison en fonction de la région AWS, mais cette propriété remplace l’URL de point de terminaison sélectionnée, ce qui permet une utilisation avec d’autres points de terminaison compatibles S3. |
Clé d’objet |
La clé d’objet S3 à utiliser. Ce nom est analogue à un nom de fichier pour les systèmes de fichiers traditionnels. |
Region |
La région AWS à laquelle se connecter. |
Service contextuel SSL |
Spécifie un service contextuel SSL facultatif qui, s’il est fourni, sera utilisé pour créer des connexions |
Signer Override |
La bibliothèque d’AWS S3 utilise par défaut le protocole Signature Version 4, mais cette propriété vous permet de spécifier le signataire version 2 pour prendre en charge des services compatibles S3 plus anciens ou même pour ajouter votre propre implémentation de signataire personnalisée. |
Version |
La version de l’objet à télécharger |
custom-signer-class-name |
Nom de classe entièrement qualifié de la classe de signataire personnalisée. Le signataire doit mettre en œuvre l’interface com.amazonaws.auth.Signer. |
custom-signer-module-location |
Liste séparée par des virgules des chemins d’accès aux fichiers et/ou aux répertoires contenant le fichier JAR du signataire personnalisé et ses dépendances (le cas échéant). |
encryption-service |
Spécifie le contrôleur de service de chiffrement utilisé pour configurer les requêtes. PutS3Object : Pour des raisons de compatibilité ascendante, cette valeur est ignorée lorsque l’option Chiffrement côté serveur est définie. FetchS3Object : Ne doit être configuré qu’en cas de chiffrement par la clé du client côté serveur, par KMS côté client et par la clé du client côté client. |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. |
range-length |
Nombre d’octets à télécharger à partir de l’objet, en commençant par le début de la plage. Une valeur vide ou une valeur qui dépasse la fin de l’objet sera lue jusqu’à la fin de l’objet. |
range-start |
La position de l’octet à laquelle commencer la lecture de l’objet. Une valeur vide ou une valeur de zéro commencera la lecture au début de l’objet. |
requester-pays |
Si true, indique que la requête consent à payer tous les frais associés à la récupération d’objets dans le compartiment S3. Cela définit l’en-tête « x-amz-request-payer » à « requester ». |
Relations¶
Nom |
Description |
|---|---|
failure |
Si le processeur n’est pas en mesure de traiter un FlowFile donné, celui-ci sera routé vers cette relation. |
success |
Les FlowFiles sont routés vers cette relation après avoir été traités correctement. |
Écrit les attributs¶
Nom |
Description |
|---|---|
s3.url |
L’URL qui peut être utilisée pour accéder à l’objet S3 |
s3.bucket |
Le nom du compartiment S3 |
path |
Le chemin du fichier |
absolute.path |
Le chemin du fichier |
filename |
Le nom du fichier |
hash.value |
La somme MD5 du fichier |
hash.algorithm |
MD5 |
mime.type |
Si S3 fournit le type de contenu/typeMIME, cet attribut contiendra ce fichier |
s3.etag |
Le ETag qui peut être utilisé pour voir si le fichier a été modifié |
s3.exception |
Nom de la classe de l’exception levée pendant l’exécution du processeur |
s3.additionalDetails |
Le détail S3 fourni à partir de l’opération échouée |
s3.statusCode |
Le code d’erreur HTTP (s’il est disponible) de l’opération qui a échoué |
s3.errorCode |
Le nom S3 de l’opération échouée |
s3.errorMessage |
Le message d’exception S3 de l’opération échouée |
s3.expirationTime |
Si le fichier a une date d’expiration, cet attribut sera ensemble, contenant les millisecondes depuis l’époque dans le fuseau horaire UTC |
s3.expirationTimeRuleId |
L’ID de la règle qui dicte le délai d’expiration de cet objet |
s3.sseAlgorithm |
Algorithme de chiffrement de l’objet côté serveur |
s3.version |
La version de l’objet S3 |
s3.encryptionStrategy |
Le nom de la stratégie de chiffrement qui a été utilisée pour stocker l’objet S3 (s’il est chiffré) |
Cas d’utilisation¶
Récupérer un fichier spécifique sur S3 |
Cas d’utilisation impliquant d’autres composants¶
Récupérer tous les fichiers d’un compartiment S3 |
Récupérer uniquement les fichiers de S3 qui répondent à certains critères spécifiés |
Récupérer les nouveaux fichiers au fur et à mesure de leur arrivée dans un compartiment S3 |