ConvertRecord 2025.5.31.15

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

Converte registros de um formato de dados para outro usando os Controller Services configurados de Record Reader e Record Writer. O leitor e gravador devem ser configurados com esquemas “correspondentes”. Com isso, queremos dizer que os esquemas devem ter os mesmos nomes de campo. Os tipos dos campos não precisam ser os mesmos se um valor de campo puder ser forçado de um tipo para outro. Por exemplo, se o esquema de entrada tiver um campo chamado “balance” do tipo double, o esquema de saída poderá ter um campo chamado “balance” com um tipo de cadeia de caracteres, double ou float. Se houver algum campo presente na entrada que não esteja presente na saída, esse campo será deixado de fora da saída. Se algum campo for especificado no esquema de saída, mas não estiver presente nos dados/esquema de entrada, o campo não estará presente na saída ou terá um valor nulo, dependendo do autor.

Tags

avro, convert, csv, freeform, generic, json, log, logs, record, schema, text

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Incluir FlowFiles de registro zero

Ao converter um FlowFile de entrada, se a conversão não resultar em dados, essa propriedade especifica se um FlowFile será ou não enviado ao relacionamento correspondente

Record Reader

Especifica o Controller Service a ser usado para ler os dados recebidos

Record Writer

Especifica o Controller Service a ser usado para gravar os registros

Relações

Nome

Descrição

failure

Se um FlowFile não puder ser transformado do formato de entrada configurado para o formato de saída configurado, o FlowFile inalterado será encaminhado para esse relacionamento

success

FlowFiles que forem transformados com sucesso serão encaminhados para esse relacionamento

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.

Casos de uso

Converta dados de um formato orientado a registros para outro