PutRedisHashRecord 2025.10.2.19

Bundle

org.apache.nifi | nifi-redis-nar

Description

Place les données des champs de l’enregistrement dans Redis en utilisant une valeur de hachage spécifiée, qui est déterminée par un RecordPath vers un champ contenant la valeur de hachage. Les champs et les valeurs de l’enregistrement sont stockés sous forme de paires clé/valeur associées par la valeur de hachage. NOTE : ni la valeur de hachage évaluée ni aucune des valeurs du champ ne peuvent être nulles. Si la valeur de hachage est nulle, le FlowFile sera routé vers failure. Pour chacune des valeurs de champ, si la valeur est nulle, ce champ ne sera pas défini dans Redis.

Balises

hash, put, record, redis

Exigences en matière d’entrées

REQUIRED

Prend en charge les propriétés dynamiques sensibles

false

Propriétés

Propriété

Description

charset

Spécifie le jeu de caractères à utiliser pour stocker les valeurs des champs d’enregistrement sous forme de chaînes. Tous les champs seront convertis en chaînes en utilisant ce jeu de caractères avant d’être stockés dans Redis.

data-record-path

This property denotes a RecordPath that will be evaluated against each incoming Record and the Record that results from evaluating the RecordPath will be sent to Redis instead of sending the entire incoming Record. The property defaults to the root “/” which corresponds to a “flat” record (all fields/values at the top level of the Record.

hash-value-record-path

Spécifie un RecordPath à évaluer pour chaque enregistrement afin de déterminer la valeur de hachage associée à tous les champs/valeurs de l’enregistrement (voir “hset” dans la documentation Redis pour plus de détails). Le RecordPath doit pointer sur un seul champ, sinon une erreur se produit.

record-reader

Spécifie le Controller Service à utiliser pour analyser les données entrantes et déterminer le schéma des données

redis-connection-pool

Relations

Nom

Description

failure

FlowFiles contenant des enregistrements avec des erreurs de traitement seront routés vers cette relation

success

FlowFiles dont tous les enregistrements sont stockés dans Redis seront routés vers cette relation.

Écrit les attributs

Nom

Description

redis.success.record.count

Nombre d’enregistrements écrits dans Redis