PutRedisHashRecord 2025.10.2.19

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

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

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