PutElasticsearchRecord 2025.10.9.21¶

バッチサイズ

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

日付形式

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

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

「エラー」関係に書き込まれたエラー記録は、エラータイプと、FlowFileに「Elasticsearch.valk.error」として追加されたFlowFile内の最初の記録に関連するエラーでグループ化されます。「見つかりませんを成功として扱う」が「false」の場合、「not_found」Elasticsearchドキュメント応答に関連付けられた記録も「エラー」関係に送信されます。

インデックス

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

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

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

ログエラー応答

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

出力エラー応答

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

結果記録ライター

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

記録のタイムスタンプを保持

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

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

scripted_upsertブール値フラグを含む記録のフィールドをポイントするRecordPath。scripted_upsertフラグを上書き操作に追加するかどうか。ドキュメントが存在するかどうかにかかわらず、Elasticsearchにスクリプトの実行を強制します。デフォルトはfalseです。（FlowFileコンテンツから）提供されたアップサートドキュメントが空の場合、クライアントサービスコントローラーサービスのSuppress Null and Empty ValuesをNever Suppressに設定しないと、「アップサート」ドキュメントはElasticsearchへのリクエストに含まれなくなり、スクリプトの実行対象の新しいドキュメントが操作で作成されないため、「not_ found」エラーが発生します

タイムスタンプ形式

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 によって正常に処理された記録数。