DeleteByQueryElasticsearch 프로세서

Snowflake Openflow의 DeleteByQueryElasticsearch 프로세서에 대한 문서예요. 쿼리를 사용해 Elasticsearch 인덱스에서 데이터를 삭제하는 프로세서로, 쿼리는 FlowFile 본문이나 Query 속성에서 불러올 수 있어요.

출처: Snowflake 문서

본문

기능 — 일반 제공(Generally Available)

Openflow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요.

번들(Bundle)

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

설명(Description)

쿼리를 사용해 Elasticsearch 인덱스에서 데이터를 삭제해요. 쿼리는 FlowFile 본문이나 Query 속성에서 불러올 수 있어요.

태그(Tags)

delete, elastic, elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, query

입력 요구사항(Input Requirement)

ALLOWED

민감 동적 속성 지원(Supports Sensitive Dynamic Properties)

false

속성(Properties)

속성(Property)	설명(Description)
Client Service	쿼리를 실행하는 데 사용할 Elasticsearch 클라이언트 서비스예요.
Index	사용할 인덱스 이름이에요.
Max JSON Field String Length	JSON 문서나 속성을 파싱할 때 문자열 값의 허용 최대 길이예요.
Query	JSON 구문의 쿼리예요. Lucene 구문이 아니에요. 예: `{"query":{"match":{"somefield":"somevalue"}}}`. 이 매개변수가 설정되지 않으면 쿼리를 FlowFile 콘텐츠에서 읽어요. 쿼리(속성과 FlowFile 콘텐츠)가 비어 있으면 기본 빈 JSON 객체를 사용하며, Elasticsearch에서 "match_all" 쿼리가 돼요.
Query Attribute	설정하면 실행한 쿼리를 각 결과 FlowFile의 지정된 속성에 설정해요.
Query Clause	JSON 구문의 "query" 절이에요. Lucene 구문이 아니에요. 예: `{"match":{"somefield":"somevalue"}}`. 쿼리가 비어 있으면 기본 JSON 객체를 사용하며, Elasticsearch에서 "match_all" 쿼리가 돼요.
Query Definition Style	프로세서가 사용할 JSON 쿼리를 정의하는 방식이에요.
Type	문서의 유형이에요(Elasticsearch에서 인덱싱·검색에 사용).

관계(Relationships)

이름(Name)	설명(Description)
failure	"by query" 작업이 실패하고 FlowFile이 읽혀졌다면 이 관계로 보내져요.
retry	서버/클러스터 가용성 때문에 실패한 모든 FlowFile은 이 관계로 가요.
success	"by query" 작업이 성공하고 FlowFile이 읽혀졌다면 이 관계로 보내져요.

속성 기록(Writes attributes)

이름(Name)	설명(Description)
elasticsearch.delete.took	삭제 작업을 완료하는 데 걸린 시간(밀리초)이에요.
elasticsearch.delete.error	삭제 실행 중 오류가 있을 때 Elasticsearch가 제공하는 오류 메시지예요.

DeleteByQueryElasticsearch 프로세서