SearchElasticsearch 2025.10.9.21¶

バンドル¶

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

説明¶

Elasticsearch JSON DSL で記述されたページ分割されたクエリ（集約を含む）を繰り返し実行できるプロセッサーです。Search After/Point in Timeクエリには、有効な「ソート」フィールドを含める必要があります。プロセッサーは、結果がなくなるか、またはページネーションキープアライブの有効期限に達するまで、複数ページの結果を取得します。その後、クエリは、取得される結果の最初のページから再開されます。

タグ¶

elasticsearch、elasticsearch7、elasticsearch8、elasticsearch9、json、ページ、クエリ、スクロール、検索

入力要件¶

FORBIDDEN

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

false

プロパティ¶

プロパティ	説明
Aggregation Results Format	アグリゲーション出力の形式。
Aggregation Results Split	すべてのアグリゲーションを含むフローファイル、または個々のアグリゲーションごとに1つのフローファイルを出力します。
Aggregations	JSON 構文で、1 つ以上のクエリ集約（または "aggs"）。例: {"items": {"terms": {"field": "product", "size":10}}}
Client Service	クエリの実行に使用する Elasticsearch クライアントサービスです。
フィールド	JSON 構文で、検索するインデックスドキュメントのフィールド。例: ["user.id", "http.response.*", {"field": "@timestamp", "format": "epoch_millis"}]。
インデックス	使用するインデックスの名前。
最大 JSON フィールド文字列長	JSON ドキュメントまたは属性をパースするときに許容される文字列値の最大長。
Output No Hits	クエリにヒットしなかった場合でも、"hits "フローファイルを出力します。trueの場合、"aggregations "が出力されても、空の "hits "フローファイルが出力されます。
Pagination Keep Alive	ページネーション "keep_alive "期間。期間 Elasticsearch はリクエストの間、スクロール/ピットカーソルを維持します（これは全てのページが返されるまでの期待時間ではなく、ページ取得間のリクエストの最大許容時間です）。
Pagination Type	使用するページネーション方法。すべてのタイプがすべてのElasticsearchバージョンで利用できるわけではありませんので、Elasticsearchのドキュメントを確認して、お客様のサービスに可用性・推奨されるタイプを確認してください。
Query	Lucene 構文ではなく JSON 構文のクエリ。例: {"query":{"match":{"somefield":"somevalue"}}}。クエリが空の場合、デフォルトの JSON オブジェクトが使用され、Elasticsearch では "match_all" クエリ結果となります。
Query Attribute	セットされた場合、実行クエリは指定された属性内の各結果フローファイルにセットされます。
Query Clause	Lucene 構文ではなく、 JSON 構文の "クエリ" 句。例: {"match":{"somefield":"somevalue"}}。クエリが空の場合、デフォルトの JSON オブジェクトが使用され、Elasticsearch では "match_all" クエリ結果となります。
Query Definition Style	JSON クエリがプロセッサーで使用されるための定義方法。
Restart On Finish	ページ分割された検索が完了したときに、プロセッサーが同じクエリで別の検索を開始するかどうか。
Script Fields	JSON 構文で、クエリ実行時にスクリプト評価を使用して作成するフィールド。例: {"test1": {"script": {"lang": "painless", "source": "doc[ 'price'].value * 2"}}, "test2": {"script": {"lang": "painless", "source": "doc[ 'price'].value * params.factor", "params": {"factor":2.0}}}}
検索結果の形式	ヒット出力の形式。
検索結果の分割	すべてのヒットを含むフローファイル、または個々のヒットに対応する1つのフローファイル、またはすべてのページングされた応答からのすべてのヒットを含む1つのフローファイルを出力します。
サイズ	クエリで検索するドキュメントの最大数。クエリがページ分割されている場合、この「サイズ」は結果セット全体の「サイズ」ではなく、クエリの各ページに適用されます。
ソート	JSON 構文で、1 つ以上のフィールドで結果を並べ替えます。例: [{"price" : {"order" : "asc", "mode" : "avg"}}, {"post_date" : {"format": "strict_date_optional_time_nanos"}}]
Type	このドキュメントのタイプ (Elasticsearch がインデックス作成と検索に使用します)。

状態管理¶

スコープ	説明
LOCAL	ページネーションの状態（scrollId、searchAfter、pitId、hitCount、pageCount、 pageExpirationTimestamp）は、Scroll/PiT （現在の時刻が最後のクエリ実行よりも遅く、Pagination Keep Alive間隔を加えた時刻）が経過するまで、このプロセッサーの呼び出しの間に保持されます。

リレーションシップ¶

名前	説明
aggregations	アグリゲーションはこのリレーションシップにルーティングされます。
failure	サーバーの可用性とは無関係な理由で失敗したすべてのフローファイルは、この関係に移動します。
hits	検索ヒットはこのリレーションにルーティングされます。
retry	サーバー/クラスタの可用性のために失敗したすべてのフローファイルは、この関係に移動します。

属性の書き込み¶

名前	説明
mime.type	application/json
aggregation.name	出力フローファイルに結果が含まれる集計の名前
aggregation.number	出力フローファイルに結果が含まれる集計の番号
ページ.番号	出力フローファイルにある、結果が返されたページ(リクエスト)の番号(1から始まる)
ヒット.数	出力フローファイル内のヒット数
elasticsearch.クエリ.エラー	インデックスのクエリにエラーが発生した場合に Elasticsearch が提供するエラーメッセージ。