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.
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 |