UpdateByQueryElasticsearch 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-elasticsearch-restapi-nar
説明¶
クエリを使用して Elasticsearch インデックスのドキュメントを更新します。クエリは、フローファイル本文またはクエリパラメーターから読み込むことができます。ロードされたクエリには、Elasticsearchの_update_by_query API が受け付ける任意の JSON 、例えば更新対象のドキュメントを識別するための「クエリ」オブジェクトと、実行する更新を定義するための「スクリプト」を含めることができます。
入力要件¶
ALLOWED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
---|---|
最大 JSON フィールド文字列長 |
JSON ドキュメントまたは属性をパースするときに許容される文字列値の最大長。 |
el-query-attribute |
セットされた場合、実行クエリは指定された属性内の各結果フローファイルにセットされます。 |
el-rest-client-service |
クエリの実行に使用する Elasticsearch クライアントサービスです。 |
el-rest-fetch-index |
使用するインデックスの名前。 |
el-rest-query |
Lucene 構文ではなく JSON 構文のクエリ。例: {"query":{"match":{"somefield":"somevalue"}}}。このパラメーターがセットされていない場合、クエリはフローファイルのコンテンツから読み込まれます。クエリ(プロパティとフローファイルの内容)が空の場合、デフォルトの空の JSON オブジェクトが使用され、Elasticsearch では「match_all」クエリ結果となります。 |
el-rest-query-clause |
Lucene 構文ではなく、 JSON 構文の "クエリ" 句。例: {"match":{"somefield":"somevalue"}}。クエリが空の場合、デフォルトの JSON オブジェクトが使用され、Elasticsearch では "match_all" クエリ結果となります。 |
el-rest-query-definition-style |
JSON クエリがプロセッサーで使用されるための定義方法。 |
el-rest-script |
JSON 構文で、手術中に実行する「スクリプト」。例: {"source": "ctx._source.count++", "lang": "painless"} |
el-rest-type |
このドキュメントのタイプ (Elasticsearch がインデックス作成と検索に使用します)。 |
リレーションシップ¶
名前 |
説明 |
---|---|
failure |
「クエリによる」操作が失敗し、フローファイルが読み込まれた場合、そのフローファイルはこのリレーションシップに送られます。 |
retry |
サーバー/クラスタの可用性のために失敗したすべてのフローファイルは、この関係に移動します。 |
success |
「クエリによる」操作が成功し、フローファイルが読み込まれた場合、そのフローファイルはこのリレーションシップに送信されます。 |
属性の書き込み¶
名前 |
説明 |
---|---|
elasticsearch.update.took |
更新操作の完了に要した時間(ms)。 |
elasticsearch.update.error |
アップデートの実行にエラーが発生した場合に Elasticsearch がプロバイダーとして提供するエラーメッセージです。 |