ScriptedTransformRecord
ScriptedTransformRecord
들어오는 FlowFile의 각 레코드에 대해 간단한 스크립트를 평가하는 프로세서예요. 스크립트로 레코드를 변환하거나, 필터링하거나, 추가 레코드를 분기(fork)할 수 있어요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-scripting-nar
설명 (Description)
들어오는 FlowFile의 각 레코드에 대해 간단한 스크립트를 평가하는 기능을 제공합니다. 스크립트는 레코드를 어떤 방식으로든 변환하거나, 레코드를 필터링하거나, 추가 레코드를 분기(fork)할 수 있습니다. 자세한 내용은 Processor's Additional Details를 참조하세요.
태그 (Tags)
filter, groovy, modify, record, script, transform, update
입력 요구사항 (Input Requirement)
REQUIRED
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Module Directory | 스크립트에 필요한 모듈을 담고 있는 파일 및/또는 디렉터리의 쉼표로 구분된 경로 목록입니다. |
| Record Reader | 들어오는 FlowFile을 Records로 파싱하는 데 사용할 Record Reader입니다. |
| Record Writer | 변환된 Records를 직렬화하는 데 사용할 Record Writer입니다. |
| Script Body | 실행할 스크립트 본문입니다. Script File 또는 Script Body 중 하나만 사용할 수 있습니다. |
| Script Engine | 스크립트에 사용할 언어입니다. |
| Script File | 실행할 스크립트 파일의 경로입니다. Script File 또는 Script Body 중 하나만 사용할 수 있습니다. |
제한 사항 (Restrictions)
| 필요한 권한 (Required Permission) | 설명 (Explanation) |
|---|---|
| execute code | 운영자에게 NiFi가 가진 모든 권한을 가정하여 임의의 코드를 실행할 수 있는 능력을 제공합니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | 변환할 수 없는 모든 FlowFile이 이 Relationship으로 라우팅됩니다. |
| success | 성공적으로 변환된 각 FlowFile이 이 Relationship으로 라우팅됩니다. |
쓰는 속성 (Writes attributes)
| 이름 (Name) | 설명 (Description) |
|---|---|
| mime.type | Record Writer가 지정한 MIME Type으로 mime.type 속성을 설정합니다. |
| record.count | FlowFile의 레코드 수입니다. |
| record.error.message | 이 속성은 실패 시 Reader 또는 Writer가 만난 오류 메시지를 제공합니다. |
함께 보기 (See also)
- org.apache.nifi.processors.jolt.JoltTransformRecord
- org.apache.nifi.processors.script.ExecuteScript
- org.apache.nifi.processors.standard.LookupRecord
- org.apache.nifi.processors.standard.QueryRecord
- org.apache.nifi.processors.standard.UpdateRecord