PutElasticsearchRecord 2025.10.9.21¶

バッチサイズ

1バッチで送信する記録数。

日付形式

Dateフィールドを記述する際に使用する形式を指定します。指定しない場合は、デフォルトの形式'yyyy-MM-dd'が使用されます。指定された場合、値は Java Simple Date Format (例えば、 MM/dd/yyyy は、2 桁の月、2 桁の日、4 桁の年が続き、01/25/2017 のようにすべて '/' 文字で区切られています) と一致する必要があります。

一括エラータイプ別に結果をグループ化

The errored records written to the "errors" relationship will be grouped by error type and the error related to the first record within the FlowFile added to the FlowFile as "elasticsearch.bulk.error". If "Treat Not Found as Success" is "false" then records associated with "not_found" Elasticsearch document responses will also be send to the "errors" relationship.

インデックス

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

インデックス操作の記録パス

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

Log Error Responses

これを有効にすると、エラーはエラーログレベルで NiFi ログに記録されます。そうでない場合は、 NiFi 全体でデバッグログが有効になっている場合にのみログが記録されます。このオプションの目的は、ユーザーがデバッグログをオンにしなくても、失敗した操作をデバッグできるようにすることです。

Output Error Responses

これを有効にすると、「error」とマークされたElasticsearchからの応答メッセージが「error_responses」リレーションシップに出力されます。これは、「successful」または「errors」リレーションシップへのフローファイルの出力には影響しません。

Result Record Writer

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

Retain Record Timestamp

@timestamp Record Pathとして使用されている既存のフィールドを保持するかどうか。

スクリプト化アップサート記録パス

A RecordPath pointing to a field in the record(s) that contains the scripted_upsert boolean flag. Whether to add the scripted_upsert flag to the Upsert Operation. 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

タイムスタンプ形式

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 のようにすべて ':' 文字で区切られています) と一致する必要があります。

タイムスタンプ値

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

型

このドキュメントのタイプ (Elasticsearch がインデックス作成と検索に使用します)。

errors

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

original

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

successful

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

elasticsearch.put.error

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

elasticsearch.put.success.count

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