MonitorActivity 2025.5.31.15

번들

org.apache.nifi | nifi-standard-nar

설명

플로우의 활동을 모니터링하고 플로우에 지정된 시간 동안 데이터가 없는 경우 표시기를 보내고 플로우의 활동이 복원되면 다시 표시기를 보냅니다

태그

active, activity, detection, flow, inactive, monitor

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

활동 복원 메시지

‘activity.restored’ 관계로 전송되는 FlowFiles 의 내용이 될 메시지입니다

지속적으로 메시지 보내기

true이면 활동이 복원될 때까지 임계값 지속 시간마다 비활성 표시기를 계속 전송하고, false이면 플로우가 처음 비활성 상태가 될 때만 표시기를 전송합니다

복사본 특성

true이면 활동을 재개한 플로우 파일의 모든 플로우 파일 특성을 새로 만든 메트릭 플로우 파일로 복사합니다

비활성 메시지

‘비활성’ 관계로 전송되는 FlowFiles 의 내용이 될 메시지입니다

모니터링 범위

플로우의 활동성을 판단하는 방법을 지정합니다.’노드’는 개별 노드에서 활동성을 개별적으로 검사한다는 의미입니다. DFM 에서 각 노드가 분산된 방식으로 플로우 파일을 수신해야 한다고 예상하는 경우 유용할 수 있습니다. ‘클러스터’는 1개 이상의 노드가 플로우 파일을 활발하게 수신하는 동안 플로우가 활동 중임을 정의합니다. NiFi 가 독립형 모드로 실행되는 경우 ‘노드’, ‘클러스터’인 경우 NiFi 가 경고 메시지를 로그하고 ‘노드’ 범위로 작동하도록 설정해야 합니다.

리포팅 노드

알림 flowfile을 비활성 및 activity.restored 관계로 보낼 노드를 지정합니다. ‘모두’를 선택하면 이 클러스터의 모든 노드가 알림 플로우 파일을 보냅니다. ‘기본’은 기본 노드에서만 플로우 파일을 전송한다는 의미입니다. NiFi 가 독립 실행형 모드로 실행 중인 경우, ‘기본’으로 설정되어 있더라도 ‘모두’로 설정해야 NiFi 가 ‘모두’로 작동합니다.

재시작 시 상태 초기화

프로세서가 시작되거나 다시 시작될 때 true로 설정하면 초기 상태가 항상 활성화됩니다. 그렇지 않으면 마지막으로 보고된 플로우 상태가 유지됩니다.

임계값 지속 시간

플로우가 비활성 상태로 간주되기까지 경과해야 하는 시간을 결정합니다

활동 대기

프로세서가 시작되거나 다시 시작될 때 true로 설정하면 이전에 활동이 있었던 경우에만 비활성 표시기를 보냅니다. 그렇지 않으면 이전에 활동이 없었더라도 비활성 표시기를 보냅니다.

상태 관리

범위

설명

CLUSTER

MonitorActivity 는 각 노드의 마지막 타임스탬프를 상태로 저장하여 클러스터 전체에서 활동을 검사할 수 있습니다. ‘복사본 특성’이 true로 설정되어 있으면 플로우 파일 특성도 유지됩니다. 로컬 범위에서는 플로우가 비활성 상태인 경우 마지막으로 알려진 활동 타임스탬프를 저장합니다.

LOCAL

MonitorActivity 는 각 노드의 마지막 타임스탬프를 상태로 저장하여 클러스터 전체에서 활동을 검사할 수 있습니다. ‘복사본 특성’이 true로 설정되어 있으면 플로우 파일 특성도 유지됩니다. 로컬 범위에서는 플로우가 비활성 상태인 경우 마지막으로 알려진 활동 타임스탬프를 저장합니다.

관계

이름

설명

activity.restored

이 관계는 FlowFiles 이 비활성 기간 후 ‘성공’으로 라우팅될 때 활동 복원됨 표시기를 전송하는 데 사용됩니다

비활성

이 관계는 임계값 지속 시간 동안’성공’으로 라우팅된 FlowFiles 이 없을 때 비활성 표시기를 전송하는 데 사용됩니다

성공

모든 수신 FlowFiles 은 성공으로 라우팅됩니다

Writes 특성

이름

설명

inactivityStartMillis

비활성 상태가 시작된 시간(epoch 이후 밀리초 단위)입니다

inactivityDurationMillis

비활성 상태가 지속된 시간(밀리초)