Notify
Notify
해제(release) 신호 식별자를 분산 캐시에 저장하는 프로세서예요. 이 신호를 캐시에서 발견하면 대응하는 Wait 프로세서에 대기 중이던 FlowFile이 해제돼요.
본문
번들 (Bundle)
org.apache.nifi | nifi-standard-nar
설명
해제 신호 식별자를 분산 캐시에 저장하는데, 선택적으로 FlowFile의 속성도 함께 저장해요. 캐시에서 이 신호가 발견되면 대응하는 Wait 프로세서에 대기 중이던 모든 FlowFile이 해제돼요.
태그
cache, distributed, map, notify, release, signal
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| attribute-cache-regex | 이름이 이 정규식과 일치하는 속성은 분산 캐시에 저장되어 대응하는 Wait 프로세서에서 해제된 FlowFile에 복사돼요. 이 값과 무관하게 uuid 속성은 캐시되지 않아요. 비워두면 어떤 속성도 캐시되지 않아요. |
| distributed-cache-service | 대응하는 Wait 프로세서에 대기 중인 파일을 해제하기 위해 해제 신호를 캐시하는 데 사용하는 Controller Service예요. |
| release-signal-id | 해제 신호 캐시 키를 결정하기 위해 FlowFile에 대해 평가되는 값 또는 Attribute Expression Language 문의 결과예요. |
| signal-buffer-count | 신호가 캐시 서비스에 통보될 때까지 버퍼링할 수 있는 들어오는 FlowFile의 최대 개수를 지정해요. 여러 들어오는 FlowFile이 같은 신호 식별자를 공유할 때 신호를 신호 식별자별로 그룹화해 캐시 서비스와의 상호작용 횟수를 줄이므로 버퍼가 클수록 성능이 좋아져요. |
| signal-counter-delta | 신호 카운터 델타를 결정하기 위해 FlowFile에 대해 평가되는 값 또는 Attribute Expression Language 문의 결과예요. 카운터가 얼마나 증가해야 하는지 지정해요. 예를 들어 여러 신호 이벤트가 상류 flow에서 배치 방식으로 처리된다면, 처리된 이벤트 수를 이 속성으로 한 번에 통보할 수 있어요. 0은 특별한 의미로, 대상 카운트를 0으로 되돌리는데 Wait Releasable FlowFile Count = Zero (0) 모드와 함께 'open-close-gate' 방식의 흐름 제어에 특히 유용해요. 1은 대응하는 Wait 프로세서를 열 수 있고, 0은 마치 게이트를 닫는 것처럼 무효화할 수 있어요. |
| signal-counter-name | 신호 카운터 이름을 결정하기 위해 FlowFile에 대해 평가되는 값 또는 Attribute Expression Language 문의 결과예요. 신호 카운터 이름은 대응하는 Wait 프로세서가 성공이나 실패 같은 서로 다른 유형의 이벤트 발생 횟수 또는 대상 데이터 소스 이름 등을 알아야 할 때 유용해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
failure |
캐시에 접근할 수 없거나 Release Signal Identifier가 null 또는 빈 값으로 평가되면 FlowFile이 이 관계로 라우팅돼요. |
success |
해제 신호가 캐시에 성공적으로 입력된 모든 FlowFile이 이 관계로 라우팅돼요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
notified |
모든 FlowFile에 'notified' 속성이 추가돼요. FlowFile이 통보되면 true, 그렇지 않으면 false 값이에요. |
더 보기 (See also)
org.apache.nifi.processors.standard.Wait