PutRedisHashRecord 2025.5.31.15

Pacote

org.apache.nifi | nifi-redis-nar

Descrição

Coloca os dados do campo de registro no Redis usando um valor de hash especificado, que é determinado por um RecordPath para um campo em cada registro que contém o valor de hash. Os campos e valores do registro são armazenados como pares de chave/valor associados pelo valor de hash. Observação: nem o valor de hash avaliado nem nenhum dos valores de campo pode ser nulo. Se o valor de hash for nulo, o FlowFile será encaminhado para à “failure”. Para cada um dos valores de campo, se o valor for nulo, esse campo não será definido no Redis.

Tags

hash, put, record, redis

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

charset

Especifica o conjunto de caracteres a ser usado ao armazenar valores de campos de registro como cadeias de caracteres. Todos os campos serão convertidos em cadeias de caracteres usando esse conjunto de caracteres antes de serem armazenados no Redis.

data-record-path

Essa propriedade indica um RecordPath que será avaliado em relação a cada registro de entrada, e o registro resultante da avaliação do RecordPath será enviado ao Redis em vez de enviar o registro inteiro de entrada. A propriedade tem como padrão a raiz “/”, que corresponde a um registro “plano” (todos os campos/valores no nível superior do registro).

hash-value-record-path

Especifica um RecordPath a ser avaliado em cada registro para determinar o valor de hash associado a todos os campos/valores do registro (consulte “hset” na documentação do Redis para obter mais detalhes). O RecordPath deve apontar exatamente para um campo ou ocorrerá um erro.

record-reader

Especifica o Controller Service a ser usado para analisar os dados recebidos e determinar o esquema de dados

redis-connection-pool

Relações

Nome

Descrição

failure

FlowFiles contendo registros com erros de processamento serão encaminhados para essa relação

success

FlowFiles com todos os registros armazenados no Redis serão encaminhados para essa relação

Grava atributos

Nome

Descrição

redis.success.record.count

Número de registros gravados no Redis