LookupRecord 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-standard-nar

説明¶

記録から 1 つまたは複数のフィールドを抽出し、それらのフィールドの値を LookupService で検索します。LookupService から結果が返された場合、その結果はオプションで記録に追加されます。この場合、プロセッサー関数はエンリッチメント・プロセッサーとして機能します。LookupService によって結果が返されたかどうかを示す「一致した」リレーションシップまたは「一致しなかった」リレーションシップ (「Routing Strategy」プロパティがそうするように構成されている場合) のいずれかに記録がルーティングされます。そのプロセッサーはルーティングプロセッサーとしても機能することを許可します。検索サービスで値を検索するために使用する「座標」は、ユーザー定義のプロパティを追加することで定義します。追加される各プロパティは、プロパティ名がマップキーになり、 RecordPath によって返される値がそのキーの値になる、マップにエントリが追加されます。RecordPath によって複数の値が返された場合、一致した記録は「unmatched」リレーションシップにルーティングされます (「Routing Strategy」プロパティの構成によっては「success」)。1つ以上のフィールドがResult RecordPath に一致する場合、一致するすべてのフィールドが更新されます。構成された LookupService に一致するものがない場合、フィールドは更新されません。つまり、記録内の既存の値をNULL値で上書きすることはありません。しかし、 LookupService によって返された結果がスキーマ (具体的には、Record Writer 用に構成されたスキーマ) でアカウントされていない場合、フィールドは FlowFile に書き出されないことに注意してください。

タグ¶

avro, convert, csv, database, db, enrichment, filter, json, logs, lookup, record, route

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
記録パスのルーティング	FlowFile の各トップレベル記録内の子記録を指す RecordPath。指定された場合、追加の RecordPath プロパティは、トップレベル記録ではなく、この子記録に対して評価されます。これにより、単一のトップレベル記録内の複数の子記録に対してエンリッチメントを実行できます。
lookup-service	各記録の値を検索するために使用する検索サービス
record-path-lookup-miss-result-cache-size	検索値/記録が何回キャッシュされるかを指定します。このプロパティをゼロに設定すると、キャッシュは行われず、各記録の各検索値に対してテーブルがクエリされます。検索テーブルが頻繁に変更される場合や、最新のデータを取得する必要がある場合は、キャッシュを使用しないでください。
record-reader	受信データの読み取りに使用するController Serviceを指定します。
record-update-strategy	このプロパティは、検索サービスによって返された値で記録を更新するときに使用するストラテジーを定義します。
record-writer	記録の書き出しに使用するController Serviceを指定します。
result-contents	記録を含む結果が得られた場合、このプロパティは、記録自体が構成パスに挿入されるか、記録のコンテンツ（つまりサブフィールド）が構成パスに挿入されるかを決定します。
result-record-path	検索サービスから返された値で値を更新すべきフィールドを指す RecordPath。指定されない場合、 FlowFile を「マッチした」リレーションシップにルーティングするか「マッチしていない」リレーションシップにルーティングするかを決定する場合を除いて、検索サービスから返される値は無視されます。
routing-strategy	検索完了後の記録のルーティング方法を指定する

リレーションシップ¶

名前	説明
failure	FlowFile をエンリッチできない場合、変更されていない FlowFile はこのリレーションシップにルーティングされます。
success	障害が発生しない限り、すべての記録はこの Relationship に送信されます。

属性の書き込み¶

名前	説明
mime.type	mime.type属性をRecord Writerで指定された MIME Typeにセットします。
record.count	FlowFile の記録数。