대기 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
해당 Notify 프로세서에서 일치하는 릴리스 신호가 분산 캐시에 저장될 때까지 수신 FlowFiles 을 ‘대기’ 관계로 라우팅합니다. 일치하는 릴리스 신호가 식별되면 대기 중인 FlowFile 은 이 ‘성공’ 관계로 라우팅됩니다. 그러면 릴리스 신호 항목이 캐시에서 제거됩니다. 해당 Notify 프로세서의 속성 캐시 정규식 속성이 올바르게 설정되어 있으면 릴리스 신호를 생성한 FlowFile 의 특성이 대기 중인 FlowFile 로 복사본이 복사됩니다. 릴리스 신호 식별자로 식별된 릴리스 신호가 캐시에 여러 개 있고 Notify 프로세서가 FlowFile 특성을 캐시에 복사본으로 구성한 경우, Wait 프로세서를 통과하는 FlowFile 은 캐시에서 릴리스 신호를 생성한 FlowFiles 의 속성(릴리스 신호 식별자로 식별됨)을 합한 값을 수신합니다. 대기 중인 FlowFiles 은 만료 기간을 초과하면 ‘만료됨’으로 라우팅됩니다. 2개 이상의 신호를 대기해야 하는 경우 ‘Target Signal Count’ 속성을 통해 원하는 신호 수를 지정하십시오. 이는 SplitText 같이 소스 FlowFile 을 여러 조각으로 분할하는 프로세서에서 특히 유용합니다. 모든 조각이 처리될 때까지 기다리려면’원본’관계를 Wait 프로세서에 연결하고,’분할’관계를 해당 Notify 프로세서에 연결하십시오. Notify 및 Wait 프로세서에 ‘${fragment.identifier}’를 ‘릴리스 신호 식별자’의 값으로 사용하고, Wait 프로세서에 ‘${fragment.count}’를 ‘대상 신호 수’의 값으로 지정하도록 구성하며,’wait’ 관계를 루프로 사용할 때는 우선순위 지정자(예: 선입선출)를 사용하는 것이 좋습니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
attribute-copy-mode |
FlowFiles 이 Notify 프로세서로 들어가는 복사본 특성을 처리하는 방법을 지정합니다 |
distributed-cache-service |
해당 Notify 프로세서의 릴리스 신호를 확인하는 데 사용되는 컨트롤러 서비스입니다 |
만료 기간 |
대기 중 FlowFiles 이 ‘만료된’ 관계로 라우팅되는 기간을 나타냅니다 |
releasable-flowfile-count |
릴리스 가능한 FlowFile 개수를 결정하기 위해 FlowFile 에 대해 평가할 값 또는 특성 표현식 언어 문의 결과입니다. 대상 신호 수가 목표 신호 수에 도달했을 때 릴리스할 수 있는 FlowFiles 수를 지정합니다. 0(0)은 특별한 의미가 있으며, 신호 수가 대상과 일치하는 한 FlowFiles 의 수에 관계없이 릴리스할 수 있습니다. |
release-signal-id |
특정 릴리스 신호 캐시에 대한 키를 지정하는 값입니다. Wait 프로세서가 처리 중인 FlowFile 을 ‘성공’ 관계로 보낼지, ‘대기’ 관계로 보낼지 결정하기 위해 프로세서는 이 키로 지정된 캐시에서 신호를 확인합니다. |
signal-counter-name |
캐시(릴리스 신호 식별자에 의해 지정됨) 내에서 신호는 서로 다른 카운터에 속할 수 있습니다. 이 속성을 지정하면 프로세서는 캐시에서 이 특정 카운터에 속한 신호의 수를 확인합니다. 지정하지 않으면 프로세서는 캐시에 있는 총 신호 수를 확인합니다. |
대상-신호-수 |
대기 프로세서가 처리한 FlowFile 을 ‘성공’ 관계로 보내기 위해 캐시에 있어야 하는 신호 수(릴리스 신호 식별자로 지정됨)입니다. 캐시의 신호 수가 이 수에 도달하면 FlowFile 은 이 ‘성공’ 관계로 라우팅되고 캐시의 신호 수가 이 값만큼 감소합니다. 신호 카운터 이름을 지정하면 이 프로세서는 특정 카운터를 확인하고, 그렇지 않으면 캐시에 있는 총 신호 수에 대해 확인합니다. |
wait-buffer-count |
앞으로 나아갈 수 있는지 확인하기 위해 버퍼링할 수 있는 최대 수신 FlowFiles 수를 지정합니다. 버퍼가 많을수록 신호 식별자별로 FlowFiles 을 그룹화하여 캐시 서비스와의 상호 작용 횟수를 줄이므로 성능이 향상될 수 있습니다. 프로세서 실행 시 신호 식별자만 처리할 수 있습니다. |
wait-mode |
알림 신호를 기다리는 FlowFile 의 처리 방법을 지정합니다 |
wait-penalty-duration |
구성하면 신호 식별자가 처리되었으나 릴리스 기준을 충족하지 못한 경우 해당 신호 식별자에게 페널티가 부여되고 해당 신호 식별자를 가진 FlowFiles 은 지정된 기간 동안 다시 처리되지 않으므로 해당 신호 식별자가 다른 신호 식별자를 처리하는 것을 차단하지 않습니다. 이는 대기 프로세서가 여러 개의 신호 식별자를 처리해야 하고 각 신호 식별자에 여러 개의 FlowFiles 이 있으며 신호 식별자 내에서 FlowFiles 릴리스 순서가 중요한 사용 사례에 유용할 수 있습니다. FlowFile 주문은 우선순위를 사용하여 구성할 수 있습니다. 중요: 큐에 대기 중인 신호는 처리할 수 있는 개수에 제한이 있으며, 대기 프로세서가 큐에 대기 중인 신호 ID를 모두 확인하지 못할 수 있습니다. 모범 사례에 대한 자세한 내용은 자세한 내용을 참조하십시오. |
관계¶
이름 |
설명 |
|---|---|
만료 |
구성된 만료 기간을 초과한 FlowFile 은 이 관계로 라우팅됩니다 |
실패 |
캐시에 연결할 수 없거나 릴리스 신호 식별자가 null 또는 비어 있는 것으로 평가되는 경우 FlowFiles 은 이 관계로 라우팅됩니다 |
성공 |
캐시에서 릴리스 신호가 일치하는 FlowFile 은 이 관계로 라우팅됩니다 |
wait |
캐시에 일치하는 릴리스 신호가 없는 FlowFile 은 이 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
wait.start.timestamp |
모든 FlowFiles 에는 파일이 이 프로세서에 처음 들어갔을 때의 초기 epoch 타임스탬프를 설정하는 ‘wait.start.timestamp’ 특성이 있습니다. 이는 FlowFile 의 만료 시간을 결정하는 데 사용됩니다. 이 특성은 FlowFile 이 실패, 만료 또는 성공으로 전송될 때 기록되지 않습니다 |
wait.counter.<counterName> |
캐시가 마지막으로 비워진 이후 캐시에 신호가 1개 이상 있는 각 카운터의 이름이 현재 FlowFile 에 특성으로 복사본으로 저장됩니다. |