ScriptedPartitionRecord 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-scripting-nar
설명¶
레코드 지향 데이터(즉, 구성된 Record Reader로 읽을 수 있는 데이터)를 수신하고 수신 플로우 파일의 각 레코드에 대해 사용자가 제공한 스크립트를 평가합니다. 그런 다음 각 레코드는 동일한 파티션을 공유하는 다른 레코드와 함께 그룹화되고 각 레코드 그룹에 대해 FlowFile 이 생성됩니다. 스크립트 평가 결과 두 레코드의 반환 값이 모두 동일한 경우 두 레코드는 동일한 파티션을 공유합니다. 이들은 동일한 파티션의 일부로 간주됩니다.
입력 요구 사항¶
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
모듈 디렉터리 |
스크립트에서 요구하는 모듈이 포함된 파일 및/또는 디렉터리 경로의 쉼표로 구분된 목록입니다. |
Record Reader |
수신 FlowFile 을 레코드로 구문 분석하는 데 사용할 Record Reader입니다 |
Record Writer |
레코드를 변환한 후 직렬화하는 데 사용할 Record Writer입니다 |
스크립트 본문 |
실행할 스크립트 본문입니다. 스크립트 파일 또는 스크립트 본문 중 하나만 사용할 수 있습니다 |
스크립트 엔진 |
스크립트에 사용할 언어 |
스크립트 파일 |
실행할 스크립트 파일의 경로입니다. 스크립트 파일 또는 스크립트 본문 중 하나만 사용할 수 있습니다 |
제한 사항¶
필수 권한 |
설명 |
|---|---|
코드 실행 |
NiFi 가 가진 모든 권한을 가정하여 임의의 코드를 실행할 수 있는 기능을 연산자 제공합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFile 을 구성된 입력 형식에서 구성된 출력 형식으로 파티션할 수 없는 경우 변경되지 않은 FlowFile 은 이 관계로 라우팅됩니다 |
원본 |
수신 FlowFile 의 모든 레코드가 파티션되면 원본 FlowFile 은 이 관계로 라우팅됩니다. |
성공 |
파티션이 성공적으로 완료된 FlowFiles 은 이 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
파티션 |
발신 플로우 파일의 파티션입니다. 스크립트에서 파티션에 null 값이 있다고 표시되면 특성은 리터럴 문자열 “<null 파티션>”(따옴표 제외)으로 설정됩니다. 그렇지 않으면 특성은 스크립트에서 반환되는 값의 문자열 표현으로 설정됩니다. |
mime.type |
Mime.type 특성을 Record Writer가 지정한 MIME 유형으로 설정합니다 |
record.count |
플로우 파일 내의 레코드 수입니다. |
record.error.message |
이 특성은 실패 시 리더 또는 작성기가 발생한 오류 메시지를 제공합니다. |
fragment.index |
단일 상위 FlowFile 에서 생성된 파티션된 FlowFiles 의 순서를 나타내는 1이 증가한 숫자입니다. |
fragment.count |
상위 FlowFile 에서 생성된 파티션된 FlowFiles 의 수입니다 |