DebugFlow 프로세서
DebugFlow 프로세서
이 문서는 Snowflake OpenFlow의 DebugFlow 프로세서에 대한 참조 문서예요. FlowFile 프레임워크의 테스트와 디버깅을 돕기 위해 다양한 응답을 명시적으로 트리거할 수 있게 해줘요.
출처: Snowflake 문서
본문
기능 — 일반 제공 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요.
Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.
번들 (Bundle)
| 그룹 | NAR |
|---|---|
| org.apache.nifi | nifi-standard-nar |
설명 (Description)
DebugFlow 프로세서는 FlowFile 수신에 대한 응답으로 다양한 응답을 명시적으로 트리거할 수 있게 해 FlowFile 프레임워크의 테스트와 디버깅을 돕고, timer 또는 cron 기반 스케줄링을 사용하는 경우 FlowFile 없이 타이머 이벤트에 대한 응답도 트리거할 수 있게 해줘요. 프로세서가 실행될 때 발생할 수 있는 다양한 실패 모드를 연습하거나 테스트하는 데 필요한 응답을 강제할 수 있어요.
태그 (Tags)
FlowFile, debug, flow, processor, test, utility
입력 요구사항 (Input Requirement)
(명시되지 않음)
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| @OnScheduled Pause Time | @OnScheduled 메서드에서 프로세서가 잠들 시간을 지정해, 프로세서가 시작하는 데 오래 걸리도록 강제할 수 있어요. |
| @OnStopped Pause Time | @OnStopped 메서드에서 프로세서가 잠들 시간을 지정해, 프로세서가 종료하는 데 오래 걸리도록 강제할 수 있어요. |
| @OnUnscheduled Pause Time | @OnUnscheduled 메서드에서 프로세서가 잠들 시간을 지정해, 사용자가 stop을 클릭할 때 프로세서가 응답하는 데 오래 걸리도록 강제할 수 있어요. |
| Content Size | FlowFile에 기록될 때마다 쓸 바이트 수예요. |
| CustomValidate Pause Time | customValidate() 메서드에서 프로세서가 잠들 시간을 지정해요. |
| Fail When @OnScheduled called | @OnScheduled로 주석 처리된 메서드가 호출될 때 프로세서가 Exception을 던져야 하는지 여부를 지정해요. |
| Fail When @OnStopped called | @OnStopped로 주석 처리된 메서드가 호출될 때 프로세서가 Exception을 던져야 하는지 여부를 지정해요. |
| Fail When @OnUnscheduled called | @OnUnscheduled로 주석 처리된 메서드가 호출될 때 프로세서가 Exception을 던져야 하는지 여부를 지정해요. |
| FlowFile Exception Class | 던질 Exception 클래스예요(java.lang. RuntimeException을 상속해야 함). |
| FlowFile Exception Iterations | Exception을 던질 FlowFiles 수예요. |
| FlowFile Failure Iterations | failure 관계로 전달할 FlowFiles 수예요. |
| FlowFile Rollback Iterations | (패널티 없이) 롤백할 FlowFiles 수예요. |
| FlowFile Rollback Penalty Iterations | 패널티와 함께 롤백할 FlowFiles 수예요. |
| FlowFile Rollback Yield Iterations | 롤백하고 yield할 FlowFiles 수예요. |
| FlowFile Success Iterations | success 관계로 전달할 FlowFiles 수예요. |
| Ignore Interrupts When Paused | 프로세서의 스레드가 (위의 "Pause Time" 속성 중 하나로 인해) 잠들어 있고 스레드가 인터럽트될 때, 프로세서가 인터럽트를 무시하고 계속 잠들지, 아니면 인터럽트를 허용할지를 나타내요. |
| No FlowFile Exception Class | FlowFile이 없을 때 던질 Exception 클래스예요(java.lang. RuntimeException을 상속해야 함). |
| No FlowFile Exception Iterations | FlowFile이 없을 때 NPE exception을 던질 횟수예요. |
| No FlowFile Skip Iterations | FlowFile이 없을 때 onTrigger를 건너뛸 횟수예요. |
| No FlowFile Yield Iterations | FlowFile이 없을 때 yield할 횟수예요. |
| OnTrigger Pause Time | onTrigger() 메서드에서 프로세서가 잠들 시간을 지정해, 프로세서가 작업을 수행하는 데 오래 걸리도록 강제할 수 있어요. |
| Write Iterations | FlowFile에 기록할 횟수예요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 처리에 실패한 FlowFiles예요. |
| success | 성공적으로 처리된 FlowFiles예요. |