LookupRecord 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Extrai um ou mais campos de um registro e procura um valor para esses campos em LookupService. Se um resultado for retornado pelo LookupService, esse resultado será opcionalmente adicionado ao registro. Nesse caso, o processador funciona como um processador de enriquecimento. Independentemente disso, o registro é então roteado para a relação “matched” ou para a relação “unmatched” (se a propriedade “Estratégia de roteamento” estiver configurada para isso), indicando se um resultado foi ou não retornado pelo LookupService, permitindo que o processador também funcione como um processador de roteamento. As “coordenadas” a serem usadas para procurar um valor no serviço de pesquisa são definidas pela adição de uma propriedade definida pelo usuário. Cada propriedade adicionada terá uma entrada adicionada a um mapa, em que o nome da propriedade se torna a chave do mapa e o valor retornado por RecordPath se torna o valor dessa chave. Se vários valores forem retornados pelo RecordPath, o registro será encaminhado para a relação “unmatched” (ou “success”, dependendo da configuração da propriedade “Estratégia de roteamento”). Se um ou mais campos corresponderem ao RecordPath do resultado, todos os campos correspondentes serão atualizados. Se não houver correspondência no LookupService configurado, nenhum campo será atualizado. Ou seja, ele não substituirá um valor existente no registro por um valor nulo. Observe, no entanto, que se os resultados retornados por LookupService não forem contabilizados em seu esquema (especificamente, o esquema configurado para o Record Writer), os campos não serão gravados no FlowFile.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Caminho do registro raiz |
Um RecordPath que aponta para um registro filho dentro de cada um dos registros de nível superior no FlowFile. Se especificado, as propriedades adicionais do RecordPath serão avaliadas em relação a esse registro filho em vez do registro de nível superior. Isso permite realizar o enriquecimento em vários registros filho dentro de um único registro de nível superior. |
lookup-service |
O serviço de pesquisa a ser usado para procurar um valor em cada registro |
record-path-lookup-miss-result-cache-size |
Define quantos valores/registros de pesquisa devem ser armazenados em cache. Definir essa propriedade como zero significa que nenhum armazenamento em cache será feito e a tabela será consultada para cada valor de pesquisa em cada registro. Se a tabela de pesquisa for alterada com frequência ou se os dados mais recentes precisarem ser recuperados, não use o cache. |
record-reader |
Especifica o Controller Service a ser usado para ler os dados recebidos |
record-update-strategy |
Essa propriedade define a estratégia a ser usada ao atualizar o registro com o valor retornado pelo serviço de pesquisa. |
record-writer |
Especifica o Controller Service a ser usado para gravar os registros |
result-contents |
Quando é obtido um resultado que contém um registro, essa propriedade determina se o próprio registro é inserido no caminho configurado ou se o conteúdo do registro (ou seja, os subcampos) será inserido no caminho configurado. |
result-record-path |
Um RecordPath que aponta para o campo cujo valor deve ser atualizado com qualquer valor retornado do serviço de pesquisa. Se não for especificado, o valor retornado do serviço de pesquisa será ignorado, exceto para determinar se o FlowFile deve ser encaminhado à relação “matched” ou “unmatched”. |
routing-strategy |
Especifica como encaminhar os registros após a conclusão de uma pesquisa |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se um FlowFile não puder ser enriquecido, o FlowFile inalterado será encaminhado para essa relação |
success |
Todos os registros serão enviados para essa relação, se configurados para isso, a menos que ocorra uma falha |
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 |