UpdateRecord 프로세서
UpdateRecord 프로세서
Openflow의 UpdateRecord 프로세서는 레코드 지향 데이터가 포함된 FlowFile의 내용을 업데이트하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-standard-nar
설명 (Description)
레코드 지향 데이터(즉, RecordReader로 읽고 RecordWriter로 쓸 수 있는 데이터)가 포함된 FlowFile의 내용을 업데이트합니다. 이 프로세서는 사용자 정의 속성을 하나 이상 추가해야 합니다. 속성 이름은 업데이트할 필드를 결정하는 RecordPath를 나타내야 합니다. 속성 값은 대체 값(선택적으로 Expression Language 사용)이거나 레코드에서 값을 추출하는 RecordPath 자체입니다. 속성 값이 RecordPath인지 리터럴 값인지는 Replacement Value Strategy 속성의 구성에 따라 결정됩니다.
태그 (Tags)
avro, csv, freeform, generic, json, log, logs, record, schema, text, update
입력 요구사항 (Input Requirement)
REQUIRED
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Record Reader | 들어오는 데이터를 읽는 데 사용할 Controller Service를 지정합니다. |
| Record Writer | 레코드를 쓰는 데 사용할 Controller Service를 지정합니다. |
| Replacement Value Strategy | 구성된 대체 값을 해석하는 방법을 지정합니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | FlowFile을 구성된 입력 형식에서 구성된 출력 형식으로 변환할 수 없으면 변경되지 않은 FlowFile이 이 관계로 라우팅됩니다. |
| success | 성공적으로 변환된 FlowFile이 이 관계로 라우팅됩니다. |
기록하는 속성 (Writes attributes)
| 이름 (Name) | 설명 (Description) |
|---|---|
| record.index | 현재 행 인덱스를 제공하며 리터럴 값 표현식 안에서만 사용할 수 있습니다. |
| record.error.message | 실패 시 Reader 또는 Writer가 만난 오류 메시지를 제공합니다. |
사용 사례 (Use cases)
- 여러 필드를 단일 필드로 결합
- 레코드 필드 값을 명시적 값으로 변경
- 한 레코드 필드의 값을 다른 레코드 필드로 복사
- 각 Record에 속성 값을 주입하여 데이터 강화
- 레코드 필드 값의 형식 변경
함께 보기 (See also)
org.apache.nifi.processors.standard.ConvertRecord