PutElasticsearchRecord 2025.5.31.15¶

最大 JSON フィールド文字列長

JSON ドキュメントまたは属性をパースするときに許容される文字列値の最大長。

el-rest-fetch-index

使用するインデックスの名前。

put-es-not_found-is-error

true の場合、 "not_found" Elasticsearch ドキュメントに関連付けられた記録は "successful" リレーションシップにルーティングされ、そうでない場合は "errors" リレーションシップにルーティングされます。Output Error Responses が "true" の場合、Elasticsearch からの "not_found" レスポンスが error_responses リレーションシップに送られます。

put-es-record-at-timestamp

タイムスタンプ(@timestamp)フィールドとして使用する値(Elasticsearch データストリームでは必須)

put-es-record-at-timestamp-path

ドキュメントのタイムスタンプを含む記録のフィールドを指す RecordPath。空白の場合、タイムスタンプはメインの@timestampプロパティを使用して決定されます。

put-es-record-at-timestamp-timestamp-format

Timestampフィールドの書き込みに使用する形式を指定します。指定しない場合、デフォルトの形式'yyyy-MM-dd HH:mm:ss'が使用されます。指定された場合、値は Java Simple Date Format (例えば、 MM/dd/yyyy HH:mm:ss のように、2 桁の月、2 桁の日、4 桁の年が続き、すべて '/' 文字で区切られ、その後に 24 時間形式で 2 桁の時、2 桁の分、2 桁の秒が続き、2017/01/25 18:04:15 のようにすべて ':' 文字で区切られています) と一致する必要があります。

put-es-record-bulk-error-groups

「errors」リレーションシップに書き込まれたエラー記録は、エラータイプごとにグループ化され、 FlowFile 内の最初の記録に関連するエラーが「elasticsearch.bulk.error」として FlowFile に追加されます。もし "Treat "Not Found" as Success" が "false" であれば、"not_found" Elasticsearchドキュメントのレスポンスに関連する記録も "errors" リレーションに送られます。

put-es-record-error-writer

Elasticsearch からのレスポンスは失敗した記録について調べられ、失敗した記録はこの record writer サービスで記録セットに書き込まれ、"errors" リレーションシップに送られます。成功した記録は、この記録作成サービスを使用して記録セットに書き込まれ、「成功した」関係に送信されます。

put-es-record-index-op

インデックスに使用する演算子のタイプ (作成、削除、インデックス、更新、upsert)

put-es-record-index-record-path

Elasticsearch で使用するインデックスフィールドを取得するための記録パス式。空白の場合、インデックスはメインインデックスプロパティを使用して決定されます。

put-es-record-reader

フローファイルからの受信記録の読み取りに使用するRecord Reader。

put-es-record-retain-id-field

ID 記録パスとして使用されている既存のフィールドを保持するかどうか。

put-es-record-scripted-upsert-path

scripted_upsert boolean フラグを含む記録内のフィールドを指す RecordPath。Upsert操作にscripted_upsertフラグを追加するかどうか。ドキュメントが存在するか否かに関わらず、Elasticsearch にスクリプトを実行させます。提供されたアップサートドキュメント (FlowFile コンテンツから) が空の場合、クライアントサービスController Serviceの Suppress Null/Empty Values を Never Suppress にセットしなければ、Elasticsearch へのリクエストに "upsert" ドキュメントが含まれず、スクリプトが実行するための新しいドキュメントが作成されないため、"not_found" エラーが発生します。

errors

（Elasticsearch内で）「エラー」となった Elasticsearch ドキュメントに対応する記録/フローファイルはここにルーティングされます。

original

リクエストに失敗せずにElasticsearchに送信されたすべてのフローファイルは、このリレーションシップに送られます。

successful

Elasticsearch ドキュメントに対応する記録/フローファイルのうち、（Elasticsearch 内で）「エラー」にならなかったものはここにルーティングされます。

elasticsearch.put.error

FlowFile 記録の解析、解析されたドキュメントの Elasticsearch への送信、または Elasticsearch レスポンスの解析に問題がある場合のエラーメッセージです。

elasticsearch.put.success.count

Elasticsearch _bulk API によって正常に処理された記録数。