FetchS3Object 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-aws-nar
Descrição¶
Recupera o conteúdo de um objeto S3 e o grava no conteúdo de um objeto FlowFile
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Serviço de provedor de credenciais AWS |
O Controller Service que é usado para obter o provedor de credenciais AWS |
Bucket |
O bucket S3 para interagir |
Tempo limite de comunicação |
O tempo de espera para estabelecer uma conexão com o AWS ou receber dados do AWS antes de atingir o tempo limite. |
URL de substituição do ponto de extremidade |
URL do ponto de extremidade a ser usado em vez do padrão do AWS, incluindo esquema, host, porta e caminho. As bibliotecas AWS selecionam um URL de ponto de extremidade com base na região AWS, mas essa propriedade substitui o URL do ponto de extremidade selecionado, permitindo o uso com outros pontos de extremidade compatíveis com S3. |
Chave do objeto |
A chave do objeto S3 a ser usada. Isso é análogo a um nome de arquivo nos sistemas de arquivo tradicionais. |
Região |
A região AWS à qual você deve se conectar. |
Serviço de contexto SSL |
Especifica um serviço de contexto SSL opcional que, se fornecido, será usado para criar conexões |
Substituição do signatário |
A biblioteca AWS S3 usa a Signature Version 4 por padrão, mas essa propriedade permite que você especifique o signatário da versão 2 para oferecer suporte a serviços compatíveis com S3 mais antigos ou até mesmo para conectar sua própria implementação de signatário personalizado. |
Versão |
A versão do objeto a ser baixada |
custom-signer-class-name |
Nome de classe totalmente qualificado da classe do assinador personalizado. O assinador deve implementar a interface com.amazonaws.auth.Signer. |
custom-signer-module-location |
Lista separada por vírgulas de caminhos para arquivos e/ou diretórios que contêm o arquivo JAR do assinador personalizado e suas dependências (se houver). |
encryption-service |
Especifica o Controller Service de criptografia usado para configurar solicitações. PutS3Object: para fins de compatibilidade com versões anteriores, esse valor é ignorado quando a opção “Criptografia do lado do servidor” é definida. FetchS3Object: só precisa ser configurado no caso das criptografias Chave de cliente do lado do servidor, KMS do lado do lado do cliente e Chave de cliente do lado do lado do cliente. |
proxy-configuration-service |
Especifica o serviço de Controller Service de configuração de proxy para a realização de proxy de solicitações de rede. |
range-length |
O número de bytes a serem baixados do objeto, a partir do início de intervalo. Um valor vazio ou um valor que se estenda além do final do objeto será lido até o final do objeto. |
range-start |
A posição de byte na qual se inicia a leitura do objeto. Um valor vazio ou um valor de zero começará a leitura no início do objeto. |
requester-pays |
Se verdadeiro, indica que o solicitante consente em pagar quaisquer encargos associados à recuperação de objetos do bucket S3. Isso define o cabeçalho “x-amz-request-payer” como “requester”. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se o processador não puder processar um determinado FlowFile, ele será encaminhado para essa relação. |
success |
FlowFiles são encaminhados para essa relação após terem sido processados com sucesso. |
Grava atributos¶
Nome |
Descrição |
|---|---|
s3.url |
O URL que pode ser usado para acessar o objeto S3 |
s3.bucket |
O nome do bucket S3 |
path |
O caminho do arquivo |
absolute.path |
O caminho do arquivo |
filename |
O nome do arquivo |
hash.value |
A soma MD5 do arquivo |
hash.algorithm |
MD5 |
mime.type |
Se o S3 fornecer o tipo de conteúdo/tipo MIME, esse atributo conterá esse arquivo |
s3.etag |
O ETag que pode ser usado para verificar se o arquivo foi alterado |
s3.exception |
O nome da classe da exceção gerada durante a execução do processador |
s3.additionalDetails |
O S3 forneceu detalhes da operação com falha |
s3.statusCode |
O código de erro HTTP (se disponível) da operação com falha |
s3.errorCode |
O moniker S3 da operação com falha |
s3.errorMessage |
A mensagem de exceção S3 da operação com falha |
s3.expirationTime |
Se o arquivo tiver uma data de expiração, esse atributo será definido, contendo os milissegundos desde a época em tempo UTC |
s3.expirationTimeRuleId |
O ID da regra que determina o tempo de expiração desse objeto |
s3.sseAlgorithm |
O algoritmo de criptografia do lado do servidor do objeto |
s3.version |
A versão do objeto S3 |
s3.encryptionStrategy |
O nome da estratégia de criptografia que foi usada para armazenar o objeto S3 (se ele estiver criptografado) |
Casos de uso¶
Obtenha um arquivo específico do S3 |
Casos de uso que envolvem outros componentes¶
Recupere todos os arquivos em um bucket S3 |
Recupere apenas arquivos do S3 que atendam a alguns critérios especificados |
Recupere novos arquivos à medida que eles chegam em um bucket S3 |