GetElasticsearch 프로세서
GetElasticsearch 프로세서
Openflow의 GetElasticsearch 프로세서는 공식 Elastic REST 클라이언트 라이브러리를 사용해 _id로 Elasticsearch에서 단일 문서를 가져오는 프로세서예요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-elasticsearch-restapi-nar
설명 (Description)
공식 Elastic REST 클라이언트 라이브러리를 사용해 _id로 Elasticsearch에서 단일 문서를 가져오는 get 프로세서예요. 문서의 전체 본문은 전송을 위해 FlowFile에 쓰기 전에 메모리로 읽어 들여진다는 점을 참고해요.
태그 (Tags)
elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, index, json, put, record
입력 요구 사항 (Input Requirement)
허용 (ALLOWED)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Attribute Name | 가져온 문서 출력에 사용할 FlowFile 속성 이름이에요. |
| Client Service | 쿼리 실행에 사용할 Elasticsearch 클라이언트 서비스예요. |
| Destination | 가져온 문서를 FlowFile 콘텐츠에 쓸지 FlowFile 속성에 쓸지 나타내요. |
| Document Id | 가져올 문서의 _id예요. |
| Index | 사용할 인덱스의 이름이에요. |
| Type | 이 문서의 유형이에요 (Elasticsearch의 인덱싱·검색에 사용). |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| document | 가져온 문서가 이 관계로 보내져요. |
| failure | 서버 가용성과 무관한 이유로 실패한 모든 flowfile이 이 관계로 보내져요. |
| not_found | 지정한 문서가 Elasticsearch 클러스터에 없으면 FlowFile이 이 관계로 보내져요. |
| retry | 서버/클러스터 가용성 때문에 실패한 모든 flowfile이 이 관계로 보내져요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
| filename | filename 속성이 문서 식별자로 설정돼요. |
| elasticsearch.index | 문서를 포함하는 Elasticsearch 인덱스예요. |
| elasticsearch.type | Elasticsearch 문서 유형이에요. |
| elasticsearch.get.error | 문서를 가져오는 중 오류가 있으면 Elasticsearch가 제공하는 오류 메시지예요. |