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

Diese Eigenschaft kennzeichnet einen RecordPath, der für jeden eingehenden Datensatz ausgewertet wird, und den Datensatz, der sich aus der Auswertung des RecordPath ergibt, wird an Redis gesendet, anstatt den gesamten eingehenden Datensatz zu senden. Die Eigenschaft ist standardmäßig auf den Stamm „/“ eingestellt, was einem vereinfachten 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