PutRedisHashRecord 2025.5.31.15¶

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	Cette propriété indique un RecordPath qui sera évalué pour chaque enregistrement entrant et l’enregistrement résultant de l’évaluation du RecordPath sera envoyé à Redis au lieu d’envoyer l’intégralité de l’enregistrement entrant. La valeur par défaut de la propriété est la racine “/”, ce qui correspond à un enregistrement “flat” (tous les champs/valeurs se trouvent au niveau supérieur de l’enregistrement).
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