ExtractRecordSchema 2025.10.9.21 — 레코드 스키마 추출 프로세서
ExtractRecordSchema 2025.10.9.21 — 레코드 스키마 추출 프로세서
ExtractRecordSchema 프로세서는 제공된 Record Reader를 사용해 FlowFile에서 레코드 스키마를 추출하고 이를 avro.schema 속성에 기록해요.
출처: Snowflake 문서
본문
기능 — 일반 공개 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP의 상용 리전에서 모든 계정에 제공돼요.
Openflow BYOC 배포는 AWS의 상용 리전에서 모든 계정에 제공돼요.
Bundle
org.apache.nifi | nifi-standard-nar
Description
제공된 Record Reader를 사용해 FlowFile에서 레코드 스키마를 추출하고 이를 avro.schema 속성에 기록해요.
Tags
avro, csv, freeform, generic, json, record, schema, text, xml
Input Requirement
REQUIRED
Supports Sensitive Dynamic Properties
false
Properties
| Property | Description |
|---|---|
| cache-size | 캐시할 스키마 수를 지정해요. 이 값은 들어오는 FlowFile에 있을 수 있는 서로 다른 스키마의 예상 개수를 반영해야 해요. 이렇게 하면 스키마 검색이 더 효율적이어져 프로세서 성능이 좋아져요 |
| record-reader | 들어오는 데이터를 읽는 데 사용할 Controller Service를 지정해요 |
Relationships
| Name | Description |
|---|---|
| failure | FlowFile의 레코드 스키마를 설정된 입력 형식에서 추출할 수 없으면 FlowFile이 이 관계로 라우팅돼요 |
| success | 레코드 스키마를 성공적으로 추출한 FlowFile이 이 관계로 라우팅돼요 |
Writes attributes
| Name | Description |
|---|---|
| record.error.message | 실패 시 Reader가 만난 오류 메시지를 제공하는 속성이에요 |
| avro.schema | 제공된 RecordReader를 사용해 입력 FlowFile에서 추출한 스키마를 제공하는 속성이에요 |