FetchFile

 

Olá, seja bem-vindo a mais uma aula do curso Desenvolvimento com Apache Nifi.

Nesta aula vamos falar sobre o processor FetchFile.

Este Processor lê o conteúdo de um arquivo do disco e o transmite para o conteúdo de um FlowFile de entrada.

Pode mover o arquivo para outro diretório após a leitura ou excluí-lo.

Ao ser pesquisado, pode aparecer nas seguintes tags:

  • local
  • files
  • filesystem
  • ingest
  • ingress
  • get
  • source
  • input
  • fetch

Abaixo temos uma lista com as suas propriedades:

  • File to Fetch : O nome de arquivo totalmente qualificado do arquivo para buscar do sistema de arquivos; Suporta linguagem de expressão, é uma propriedade obrigatória e o valor default dessa propriedade é: ${absolute.path}/${filename}
  • Completion Strategy : Especifica o que fazer com o arquivo original no sistema de arquivos depois que ele for puxado para o NiFi , é uma propriedade obrigatória e o valor default dessa propriedade é: None
  • Move Destination Directory : O diretório para o qual mover o arquivo original uma vez obtido do sistema de arquivos. Esta propriedade é ignorada, a menos que a Estratégia de Conclusão esteja definida como ""Move File"". Se o diretório não existir, ele será criado. Suporta linguagem de expressão , por ser uma propriedade opcional não existe um valor default nessa propriedade.
  • Move Conflict Strategy : Se a Estratégia de Conclusão estiver configurada para Mover Arquivo e já existir um arquivo no diretório de destino com o mesmo nome, esta propriedade especifica como esse conflito de nomenclatura deve ser resolvido , é uma propriedade obrigatória e o valor default dessa propriedade é: Rename
  • Log level when file not found : Nível de log a ser usado caso o arquivo não exista quando o processador for acionado , é uma propriedade obrigatória e o valor default dessa propriedade é: ERROR
  • Log level when permission denied : Nível de log a ser usado caso o usuário não tenha permissões suficientes para ler o arquivo , é uma propriedade obrigatória e o valor default dessa propriedade é: ERROR

Os relacionamentos permitidos para direcionar ou terminar um flowfile são:

  • success= Qualquer FlowFile obtido com sucesso do sistema de arquivos será transferido para este relacionamento.
  • not.found= Qualquer FlowFile que não pôde ser obtido do sistema de arquivos porque o arquivo não foi encontrado será transferido para este Relacionamento.
  • permission.denied= Qualquer FlowFile que não pôde ser obtido do sistema de arquivos devido ao usuário que executa o NiFi não ter permissões suficientes será transferido para este relacionamento.
  • failure= Qualquer FlowFile que não possa ser obtido do sistema de arquivos por qualquer motivo que não seja permissões insuficientes ou o arquivo não existente será transferido para este relacionamento.