ScriptedValidateRecord 2025.5.31.15

Pacote

org.apache.nifi | nifi-scripting-nar

Descrição

Esse processador oferece a capacidade de validar registros nos FlowFiles usando o script fornecido pelo usuário. Espera-se que o script tenha um registro como argumento de entrada e retorne com um valor booliano. Com base nesse resultado, o processador categoriza os registros como “válidos” ou “inválidos” e os encaminha para a respectiva relação em lote. Além disso, o FlowFile original será encaminhado para a relação “original” ou, em caso de processamento malsucedido, para a relação “failed”.

Tags

groovy, record, script, validate

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Diretório de módulos

Lista separada por vírgulas de caminhos para arquivos e/ou diretórios que contêm módulos exigidos pelo script.

Record Reader

O Record Reader a ser usado para analisar o FlowFile de entrada em registros

Record Writer

O Record Writer a ser usado para serializar registros depois de terem sido transformados

Corpo do script

Corpo do script a ser executado. Somente um dos itens de arquivo de script ou corpo de script pode ser usado

Mecanismo do script

O idioma a ser usado no script

Arquivo do script

Caminho para o arquivo de script a ser executado. Somente um dos itens de arquivo de script ou corpo de script pode ser usado

Restrições

Permissão necessária

Explicação

executar código

Fornece ao operador a capacidade de executar código arbitrário assumindo todas as permissões que o NiFi possui.

Relações

Nome

Descrição

failure

Em caso de qualquer problema durante o processamento do FlowFile de entrada, o FlowFile de entrada será encaminhado para essa relação.

invalid

O FlowFile contendo os registros inválidos do FlowFile de entrada será encaminhado para essa relação. Se não houver registros inválidos, nenhum FlowFile será encaminhado para essa relação.

original

Após o processamento bem-sucedido, o FlowFile de entrada será transferido para essa relação. Isso acontece independentemente de os FlowFiles poderem ser roteados para relações “valid” e “invalid”.

valid

O FlowFile contendo os registros válidos do FlowFile de entrada será encaminhado para essa relação. Se não houver registros válidos, nenhum FlowFile será encaminhado para essa relação.

Grava atributos

Nome

Descrição

mime.type

Define o atributo mime.type para o tipo MIME especificado pelo Record Writer

record.count

O número de registros no FlowFile.

record.error.message

Esse atributo fornece, em caso de falha, a mensagem de erro encontrada pelo leitor ou gravador.

Consulte também