UpdateRecord 2025.5.31.15

バンドル

org.apache.nifi | nifi-standard-nar

説明

記録指向のデータ(すなわち、 RecordReader から読み取ったり、 RecordWriter から書き込んだりできるデータ)を含む FlowFile の内容を更新します。このプロセッサーでは、少なくとも 1 つのユーザー定義プロパティを追加する必要があります。プロパティの名前は、更新されるべきフィールドを決定する RecordPath を示すべきです。Propertyの値は、置換値(オプションで式言語を使用)か、記録から値を抽出する RecordPath そのものです。Property 値が RecordPath である かリテラル値であるかは、<Replacement Value Strategy> Property の構成によって決まります。

タグ

avro, csv, freeform, generic, json, log, logs, record, schema, text, update

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

Record Reader

受信データの読み取りに使用するController Serviceを指定します。

Record Writer

記録の書き出しに使用するController Serviceを指定します。

代替価値ストラテジー

構成された置換値の解釈方法を指定します。

リレーションシップ

名前

説明

failure

FlowFile が構成された入力形式から構成された出力形式に変換できない場合、変更されていない FlowFile は、この関係にルーティングされます。

success

FlowFiles 変換に成功すると、このリレーションシップにルーティングされます。

属性の書き込み

名前

説明

record.index

この属性は現在の行インデックスを提供し、リテラル値式の内部でのみ利用可能です。

record.error.message

この属性は、エラー時にリーダーまたはライターが遭遇したエラーメッセージを提供します。

ユースケース

複数のフィールドを1つのフィールドにまとめます。

記録フィールドの値を明示的な値に変更します。

ある記録フィールドの値を別の記録フィールドにコピーします。

各記録に属性の値を注入することで、データを充実させます。

記録フィールドの値の形式を変更します。

こちらもご覧ください