Wait 2025.10.2.19¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
해당 Notify 프로세서에서 일치하는 릴리스 신호가 분산 캐시에 저장될 때까지 수신 FlowFiles 을 ‘대기’ 관계로 라우팅합니다. 일치하는 릴리스 신호가 식별되면 대기 중인 FlowFile은 ‘성공’ 관계로 라우팅됩니다. 그러면 릴리스 신호 항목이 캐시에서 제거됩니다. 릴리스 신호를 생성한 FlowFile의 특성은 해당 알림 프로세서의 특성 캐시 정규식 속성이 올바르게 설정된 경우 대기 중인 FlowFile에 복사됩니다. 캐시에 릴리스 신호 식별자로 식별되는 여러 릴리스 신호가 있고 알림 프로세서가 FlowFile 특성을 캐시에 복사하도록 구성된 경우 대기 프로세서를 전달하는 FlowFile은 캐시에서 릴리스 신호를 생성한 FlowFiles의 특성(릴리스 신호 식별자로 식별) 조합을 수신합니다. 대기 중인 FlowFiles는 만료 기간을 초과하는 경우 ‘만료됨’으로 라우팅됩니다. 둘 이상의 신호를 기다려야 하는 경우 ‘목표 신호 수’ 속성을 통해 원하는 신호 수를 지정하십시오. 이 속성은 소스 FlowFile을 여러 조각으로 분할하는 프로세스에 특히 유용합니다(예: SplitText). 모든 조각이 처리될 때까지 기다리려면 ‘원래’ 관계를 대기 프로세서에 연결하고 ‘분할’ 관계를 해당 알림 프로세서에 연결합니다. ‘${fragment.identifier}’를 ‘릴리스 신호 식별자’ 값으로 사용하고 대기 프로세서에서 ‘${fragment.count}’를 ‘목표 신호 수’ 값으로 지정하도록 알림 및 대기 프로세서를 구성합니다. ‘대기’ 관계를 루프로 사용할 때는 우선 순위 지정기(예: 선입선출)를 사용하는 것이 좋습니다.
입력 요구 사항¶
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 에 특성으로 복사본으로 저장됩니다. |