PutElasticsearchRecord 2025.10.9.21¶

Batch Size

한 번에 배치로 전송할 레코드의 수입니다.

Date Format

날짜 필드를 작성할 때 사용할 형식을 지정합니다. 지정하지 않으면 기본 형식인 ‘yyyy-MM-dd’가 사용됩니다. 지정하는 경우 값은 Java 단순 날짜 형식과 일치해야 합니다(예: 01/25/2017과 같이 MM/dd/yyyy의 경우 2자리 월, 2자리 일, 4자리 연도, 모두’/’문자로 구분).

대량 오류 유형별로 결과 그룹화

The errored records written to the “errors” relationship will be grouped by error type and the error related to the first record within the FlowFile added to the FlowFile as “elasticsearch.bulk.error”. If “Treat Not Found as Success” is “false” then records associated with “not_found” Elasticsearch document responses will also be send to the “errors” relationship.

인덱스

사용할 인덱스의 이름입니다.

인덱스 작업 레코드 경로

Elasticsearch에서 사용할 인덱스 작업 필드를 검색하기 위한 레코드 경로 식입니다. 비워두면 기본 인덱스 작업 속성을 사용하여 인덱스 작업이 결정됩니다.

Log Error Responses

이 옵션을 활성화하면 오류 로그 수준에서 NiFi 로그에 오류가 기록됩니다. 그렇지 않으면 전체적으로 NiFi 에서 디버그 로깅이 활성화된 경우에만 로그가 기록됩니다. 이 옵션의 목적은 사용자가 디버그 로깅을 켜지 않고도 실패한 작업을 디버깅할 수 있는 기능을 제공하기 위한 것입니다.

Output Error Responses

이 기능이 활성화되면 “오류”로 표시된 Elasticsearch의 응답 메시지가 “error_responses” 관계로 출력됩니다. 이는 “성공” 또는 “오류” 관계에 대한 flowfile의 출력에 영향을 주지 않습니다.

Result Record Writer

Elasticsearch의 응답에서 실패한 레코드가 있는지 검사하고 실패한 레코드는 이 Record Writer 서비스를 통해 레코드 세트에 작성되어 “오류” 관계로 전송됩니다. 성공한 레코드는 이 레코드 작성 서비스를 통해 설정된 레코드 세트에 기록되어 ‘성공’ 관계로 전송됩니다.

Retain Record Timestamp

타임스탬프 레코드 경로로 사용되는 기존 필드를 유지할지 여부입니다.

스크립팅된 업서트 레코드 경로

A RecordPath pointing to a field in the record(s) that contains the scripted_upsert boolean flag. Whether to add the scripted_upsert flag to the Upsert Operation. Forces Elasticsearch to execute the Script whether or not the document exists, defaults to false. If the Upsert Document provided (from FlowFile content) will be empty, but sure to set the Client Service controller service’s Suppress Null and Empty Values to Never Suppress or no “upsert” doc will be, included in the request to Elasticsearch and the operation will not create a new document for the script to execute against, resulting in a “not_found” error

타임스탬프 형식

타임스탬프 필드를 작성할 때 사용할 형식을 지정합니다. 지정하지 않으면 기본 형식인 ‘yyyy-MM-dd HH:mm:ss’가 사용됩니다. 지정된 경우, 값은 Java Simple Date Format 형식입니다(예: MM/dd/yyyy HH:mm:ss는 두 자리의 월, 그 다음에 두 자리의 일, 그 다음에 네 자리의 연도이며, 모두 ‘/’ 문자로 구분됩니다. 01/25/2017 18:04:15와 같이 그 다음에는 24시간 형식의 두 자리의 시간이, 그 다음에 두 자리의 분, 그 다음에 두 자리의 초가 ‘:’ 문자로 구분되어 이어집니다).

타임스탬프 값

@timestamp 필드로 사용할 값(Elasticsearch Data Streams에 필수)

타입

이 문서의 유형(인덱스 및 검색을 위해 Elasticsearch에서 사용)입니다.

오류

“오류”를 발생시킨 Elasticsearch 문서에 해당하는 레코드/Flowfile(Elasticsearch 내에서)이 여기로 라우팅됩니다.

원본

요청 실패 없이 Elasticsearch로 전송되는 모든 Flowfile은 이 관계로 이동합니다.

성공

(Elasticsearch 내에서) “오류”를 발생시키지 않은 Elasticsearch 문서에 해당하는 레코드/Flowfile은 여기로 라우팅됩니다.

elasticsearch.put.error

FlowFile 레코드를 구문 분석하거나, 구문 분석된 문서를 Elasticsearch로 보내거나, Elasticsearch 응답을 구문 분석하는 데 문제가 있는 경우 오류 메시지입니다.

elasticsearch.put.success.count

Elasticsearch _bulk API 에서 성공적으로 처리된 레코드의 수입니다.