UpdateByQueryElasticsearch 2025.10.9.21¶

번들¶

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

설명¶

쿼리를 사용해 Elasticsearch 인덱스에서 문서를 업데이트합니다. 쿼리는 flowfile 본문 또는 쿼리 매개 변수에서 로딩할 수 있습니다. 로딩된 쿼리에는 업데이트할 문서를 식별하는 “쿼리” 오브젝트와 업데이트 성능을 정의하는 “스크립트”와 같이 Elasticsearch의 _update_by_query API 에서 허용하는 모든 JSON 을 포함할 수 있습니다.

태그¶

elastic, elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, query, update

입력 요구 사항¶

ALLOWED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Client Service	쿼리 실행에 사용할 Elasticsearch 클라이언트 서비스입니다.
Index	사용할 인덱스의 이름입니다.
Max JSON Field String Length	JSON 문서 또는 특성을 구문 분석할 때 허용되는 문자열 값의 최대 길이입니다.
Query	Lucene 구문이 아닌 JSON 구문의 쿼리입니다. 예: {“query”:{“match”:{“somefield”:”somevalue”}}}. 이 매개 변수를 설정하지 않으면 flowfile 내용에서 쿼리를 읽습니다. 쿼리(속성 및 Flowfile 내용)가 비어 있는 경우, 기본 빈 JSON 오브젝트가 사용되며, 이는 Elasticsearch에서 “match_all” 쿼리 결과를 생성합니다.
Query Attribute	설정하면 실행된 쿼리가 지정된 특성의 각 결과 flowfile에 설정됩니다.
Query Clause	루씬 구문이 아닌 JSON 구문의 “쿼리” 절입니다. 예: {“match”:{“somefield”:”somevalue”}}. 쿼리가 비어 있으면 기본 JSON 오브젝트가 사용되며, 이는 Elasticsearch에서 “match_all” 쿼리를 생성합니다.
Query Definition Style	프로세서에서 사용하기 위해 JSON 쿼리를 정의하는 방법입니다.
Script	작업 중에 실행할 “스크립트”(JSON 구문)입니다. 예: {“source”: “ctx._source.count++”, “lang”: “painless”}
Type	이 문서의 유형(인덱스 및 검색을 위해 Elasticsearch에서 사용)입니다.

관계¶

이름	설명
실패	‘쿼리별’ 작업이 실패하고 flowfile을 읽은 경우 이 관계로 전송됩니다.
retry	서버/클러스터 가용성으로 인해 실패하는 모든 flowfile은 이 관계로 이동합니다.
성공	‘쿼리별’ 작업이 성공하고 flowfile을 읽으면 이 관계로 전송됩니다.

Writes 특성¶

이름	설명
elasticsearch.update.took	업데이트 작업을 완료하는 데 걸린 시간(ms)입니다.
elasticsearch.update.error	업데이트를 실행하는 데 오류가 있는 경우 Elasticsearch에서 제공하는 오류 메시지입니다.