MonitorActivity
MonitorActivity
Flow에 활동(activity)이 있는지를 감시하고, 일정 시간 데이터가 없으면 비활성 신호를, 다시 활동이 회복되면 복구 신호를 보내는 프로세서예요.
본문
번들 (Bundle)
org.apache.nifi | nifi-standard-nar
설명
Flow의 활동을 감시하고, 지정한 시간 동안 데이터가 없으면 비활성 지표를, Flow의 활동이 다시 회복되면 그 지표를 보내요.
태그
active, activity, detection, flow, inactive, monitor
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Activity Restored Message | 'activity.restored' 관계로 보내는 FlowFile의 내용이 될 메시지예요. |
| Continually Send Messages | true면 활동이 회복될 때까지 Threshold Duration 간격으로 비활성 지표를 계속 보내요. false면 Flow가 처음 비활성 상태가 될 때만 지표를 보내요. |
| Copy Attributes | true면 활동을 회복한 FlowFile의 모든 속성을 새로 만든 지표 FlowFile에 복사해요. |
| Inactivity Message | 'inactive' 관계로 보내는 FlowFile의 내용이 될 메시지예요. |
| Monitoring Scope | Flow의 활성 여부를 판단하는 방식을 정해요. 'node'는 각 노드에서 개별적으로 활성 여부를 검사해요. 분산 방식으로 각 노드가 FlowFile을 받아야 하는 경우 유용해요. 'cluster'는 최소한 하나의 노드가 활발하게 FlowFile을 받으면 Flow가 활성 상태로 간주돼요. NiFi가 독립 실행(standalone) 모드라면 'node'로 설정해야 해요. 'cluster'로 설정하면 NiFi가 경고를 기록하고 'node' 범위로 동작해요. |
| Reporting Node | inactive 및 activity.restored 관계에 알림 FlowFile을 보낼 노드를 정해요. 'all'이면 클러스터의 모든 노드가 알림 FlowFile을 보내요. 'primary'면 primary 노드에서만 보내요. NiFi가 독립 실행 모드라면 'all'로 설정해야 해요. 'primary'로 설정해도 NiFi는 'all'로 동작해요. |
| Reset State on Restart | 프로세서가 시작되거나 재시작될 때 true면 초기 상태는 항상 활성 상태예요. 그렇지 않으면 마지막으로 보고된 Flow 상태가 유지돼요. |
| Threshold Duration | Flow를 비활성 상태로 간주하기까지 경과해야 하는 시간이에요. |
| Wait for Activity | 프로세서가 시작되거나 재시작될 때 true면 이전에 활동이 있었을 때만 비활성 지표를 보내요. 그렇지 않으면 이전 활동 여부와 무관하게 비활성 지표를 보내요. |
상태 관리 (State management)
| 범위 | 설명 |
|---|---|
LOCAL |
MonitorActivity는 각 노드의 마지막 타임스탬프를 상태로 저장해서 클러스터 전체의 활동을 검사해요. 'Copy Attribute'가 true면 FlowFile 속성도 함께 유지돼요. 로컬 범위에서는 Flow가 비활성일 때 마지막으로 알려진 활동 타임스탬프를 저장해요. |
CLUSTER |
MonitorActivity는 각 노드의 마지막 타임스탬프를 상태로 저장해서 클러스터 전체의 활동을 검사해요. 'Copy Attribute'가 true면 FlowFile 속성도 함께 유지돼요. 로컬 범위에서는 Flow가 비활성일 때 마지막으로 알려진 활동 타임스탬프를 저장해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
activity.restored |
비활성 기간 이후 FlowFile이 'success'로 라우팅될 때 Activity Restored 지표를 전달하는 데 사용돼요. |
inactive |
Threshold Duration 시간 동안 'success'로 라우팅된 FlowFile이 없을 때 Inactivity 지표를 전달하는 데 사용돼요. |
success |
들어오는 모든 FlowFile이 success로 라우팅돼요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
inactivityStartMillis |
비활성이 시작된 시각을 Epoch 이후 밀리초로 나타낸 값이에요. |
inactivityDurationMillis |
비활성이 지속된 밀리초 수예요. |