PutRedisHashRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-redis-nar

Beschreibung¶

Speichert Datensatzfelddaten unter Verwendung eines angegebenen Hashwerts in Redis, der durch einen RecordPath zu einem Feld in jedem Datensatz bestimmt wird, das den Hashwert enthält. Die Datensatzfelder und -werte werden als Schlüssel-Wert-Paare gespeichert, die durch den Hashwert verknüpft sind. NOTE: Weder der ausgewertete Hashwert noch einer der Feldwerte darf null sein. Wenn der Hashwert Null ist, wird das FlowFile als Fehler weitergeleitet. Für jeden der Feldwerte gilt: Wenn der Wert Null ist, wird das in Redis Feld nicht gesetzt.

Tags¶

hash, put, record, redis

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Zeichensatz	Gibt den Zeichensatz an, der beim Speichern von Datensatzfeldwerten als Zeichenfolgen verwendet werden soll. Alle Felder werden vor der Speicherung in Redis mit diesem Zeichensatz in Zeichenfolgen konvertiert.
data-record-path	Diese Eigenschaft bezeichnet einen RecordPath, der für jeden eingehenden Datensatz ausgewertet wird. Der aus der Auswertung des RecordPath resultierende Datensatz wird ergibt, wird anstelle des gesamten eingehenden Datensatzes an Redis gesendet. Die Eigenschaft ist standardmäßig auf das Stammverzeichnis „/“ eingestellt, das einem „flachen“ Datensatz entspricht (alle Felder/Werte auf der obersten Ebene des Datensatzes).
hash-value-record-path	Gibt einen RecordPath an, der gegen jeden Datensatz ausgewertet wird, um den Hashwert zu ermitteln, der mit allen Datensatzfeldern/-werten verknüpft ist (siehe „hset“ in der Redis-Dokumentation für weitere Details). Der RecordPath muss auf genau ein Feld zeigen, sonst tritt ein Fehler auf.
record-reader	Gibt den Controller Service an, der für das Parsen eingehender Daten und die Bestimmung des Datenschemas verwendet werden soll
redis-connection-pool

Beziehungen¶

Name	Beschreibung
failure	FlowFiles, die Datensätze mit Verarbeitungsfehlern enthalten, werden an diese Beziehung weitergeleitet.
success	FlowFiles, die alle Datensätze in Redis gespeichert haben, werden an diese Beziehung weitergeleitet.

Schreibt Attribute¶

Name	Beschreibung
redis.success.record.count	Anzahl der in Redis geschriebenen Datensätze