Wait 2025.10.2.19¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
Routes incoming FlowFiles to the ‘wait’ relationship until a matching release signal is stored in the distributed cache from a corresponding Notify processor. When a matching release signal is identified, a waiting FlowFile is routed to the ‘success’ relationship. The release signal entry is then removed from the cache. The attributes of the FlowFile that produced the release signal are copied to the waiting FlowFile if the Attribute Cache Regex property of the corresponding Notify processor is set properly. If there are multiple release signals in the cache identified by the Release Signal Identifier, and the Notify processor is configured to copy the FlowFile attributes to the cache, then the FlowFile passing the Wait processor receives the union of the attributes of the FlowFiles that produced the release signals in the cache (identified by Release Signal Identifier). Waiting FlowFiles will be routed to ‘expired’ if they exceed the Expiration Duration. If you need to wait for more than one signal, specify the desired number of signals via the ‘Target Signal Count’ property. This is particularly useful with processors that split a source FlowFile into multiple fragments, such as SplitText. In order to wait for all fragments to be processed, connect the ‘original’ relationship to a Wait processor, and the ‘splits’ relationship to a corresponding Notify processor. Configure the Notify and Wait processors to use the ‘${fragment.identifier}’ as the value of ‘Release Signal Identifier’, and specify ‘${fragment.count}’ as the value of ‘Target Signal Count’ in the Wait processor. It is recommended to use a prioritizer (for instance First In First Out) when using the ‘wait’ relationship as a loop.
입력 요구 사항¶
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 에 특성으로 복사본으로 저장됩니다. |