PutElasticsearchJson 2025.10.9.21¶

バンドル¶

org.apache.nifi | nifi-elasticsearch-restapi-nar

説明¶

Elasticsearch put プロセッサーは、公式の Elastic REST クライアントライブラリを使用します。各 FlowFile は Elasticsearch _bulk API に送られるドキュメントとして扱われます。Elasticsearch に送信される各リクエストには、複数の FlowFiles をバッチすることができます。

タグ¶

elasticsearch、elasticsearch7、elasticsearch8、elasticsearch9、インデックス、json、put

入力要件¶

REQUIRED

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

false

プロパティ¶

プロパティ	説明
バッチサイズ	1バッチで送信する FlowFiles の希望数。
文字セット	ドキュメントデータの文字セットを指定します。
Client Service	クエリの実行に使用する Elasticsearch クライアントサービスです。
Dynamic Templates	ドキュメントのdynamic_templates。JSON オブジェクトとして解析可能でなければなりません。Elasticsearch 7+が必要
識別子属性	ドキュメントの識別子を含む FlowFile 属性の名前。Index Operation が "index" の場合、このプロパティは空のままか、空の値で評価されます。この場合、ドキュメントの識別子は Elasticsearch によって自動生成されます。他のすべてのインデックス演算子では、属性は空でない値で評価されなければなりません。
インデックス	使用するインデックスの名前。
インデックス操作	インデックスに使用する演算子のタイプ (作成、削除、インデックス、更新、upsert)
Log Error Responses	これを有効にすると、エラーはエラーログレベルで NiFi ログに記録されます。そうでない場合は、 NiFi 全体でデバッグログが有効になっている場合にのみログが記録されます。このオプションの目的は、ユーザーがデバッグログをオンにしなくても、失敗した操作をデバッグできるようにすることです。
最大 JSON フィールド文字列長	JSON ドキュメントまたは属性をパースするときに許容される文字列値の最大長。
Output Error Responses	これを有効にすると、「error」とマークされたElasticsearchからの応答メッセージが「error_responses」リレーションシップに出力されます。これは、「successful」または「errors」リレーションシップへのフローファイルの出力には影響しません。
Script	ドキュメントの更新/アップサートのスクリプト。Update/Upsert 操作にのみ適用されます。JSON オブジェクトとして解析可能でなければなりません。空白の場合、ドキュメントの更新/アップサートに FlowFile のコンテンツが使用されます。
Scripted Upsert	Whether to add the scripted_upsert flag to the Upsert Operation. If true, forces Elasticsearch to execute the Script whether or not the document exists, defaults to false. If the Upsert Document provided (from FlowFile content) will be empty, but sure to set the Client Service controller service's Suppress Null and Empty Values to Never Suppress or no "upsert" doc will be, included in the request to Elasticsearch and the operation will not create a new document for the script to execute against, resulting in a "not_found" error
「見つかりません」を成功として扱う	true の場合、 "not_found" Elasticsearch ドキュメントに関連付けられた記録は "successful" リレーションシップにルーティングされ、そうでない場合は "errors" リレーションシップにルーティングされます。Output Error Responses が "true" の場合、Elasticsearch からの "not_found" レスポンスが error_responses リレーションシップに送られます。
型	このドキュメントのタイプ (Elasticsearch がインデックス作成と検索に使用します)。

リレーションシップ¶

名前	説明
errors	（Elasticsearch内で）「エラー」となった Elasticsearch ドキュメントに対応する記録/フローファイルはここにルーティングされます。
failure	サーバーの可用性とは無関係な理由で失敗したすべてのフローファイルは、この関係に移動します。
original	リクエストに失敗せずにElasticsearchに送信されたすべてのフローファイルは、このリレーションシップに送られます。
retry	サーバー/クラスタの可用性のために失敗したすべてのフローファイルは、この関係に移動します。
successful	Elasticsearch ドキュメントに対応する記録/フローファイルのうち、（Elasticsearch 内で）「エラー」にならなかったものはここにルーティングされます。

属性の書き込み¶

名前	説明
elasticsearch.put.error	FlowFile のパース、パースされたドキュメントの Elasticsearch への送信、または Elasticsearch のレスポンスのパースに問題がある場合のエラーメッセージです。
elasticsearch.bulk.error	Elasticsearch でのドキュメント処理中にエラーが発生した場合の _bulk レスポンス。

こちらもご覧ください¶

org.apache.nifi.processors.elasticsearch.PutElasticsearchRecord