ScriptedFilterRecord
ScriptedFilterRecord
사용자가 제공한 스크립트를 사용해 FlowFile에서 레코드를 필터링하는 프로세서예요. 각 레코드를 스크립트로 평가해 boolean 값을 반환하고, "true"인 레코드만 matching 관계로 보내요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-scripting-nar
설명 (Description)
이 프로세서는 사용자가 제공한 스크립트를 사용해 FlowFile에서 레코드를 필터링하는 기능을 제공합니다. 모든 레코드는 스크립트로 평가되며, 스크립트는 boolean 값을 반환해야 합니다. "true" 결과를 가진 레코드는 일괄적으로 "matching" 관계로 라우팅됩니다. 다른 레코드는 필터링되어 제외됩니다.
태그 (Tags)
filter, groovy, record, script
입력 요구사항 (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 처리 중 문제가 발생한 경우, 들어오는 FlowFile이 이 관계로 라우팅됩니다. |
| original | 성공적으로 처리된 후 들어오는 FlowFile이 이 관계로 전송됩니다. 필터링되거나 남은 레코드 수와 관계없이 발생합니다. |
| success | 원본 FlowFile의 일치하는 레코드가 이 관계로 라우팅됩니다. 일치하는 레코드가 없으면 여기로 라우팅되는 FlowFile이 없습니다. |
쓰는 속성 (Writes attributes)
| 이름 (Name) | 설명 (Description) |
|---|---|
| mime.type | Record Writer가 지정한 MIME Type으로 mime.type 속성을 설정합니다. |
| record.count | flow file 내의 레코드 수입니다. |
| record.error.message | 이 속성은 실패 시 Reader 또는 Writer가 만난 오류 메시지를 제공합니다. |
함께 보기 (See also)
- org.apache.nifi.processors.script.ScriptedPartitionRecord
- org.apache.nifi.processors.script.ScriptedTransformRecord
- org.apache.nifi.processors.script.ScriptedValidateRecord