MonitorActivity

Описание

Отслеживает активность потока и отправляет индикатор, когда в потоке не было данных в течение указанного времени, и снова, когда активность потока восстанавливается.

Теги

monitor, flow, active, inactive, activity, detection

Свойства

Название	Описание
Threshold Duration	Определяет, сколько времени должно пройти, прежде чем поток будет считаться неактивным Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Continually Send Messages	Если значение true, индикатор неактивности будет отправляться непрерывно в течение каждого порогового периода времени, пока активность не восстановится; если значение false, индикатор будет отправляться только тогда, когда поток впервые станет неактивным
Inactivity Message	Сообщение, которое будет содержаться в файлах потока, отправляемых в неактивное состояние Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Activity Restored Message	Сообщение, которое будет содержаться в файлах Flow, отправляемых в отношение «activity.restored» Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Wait for Activity	Если процессор запускается или перезапускается, то при значении true отправляется только индикатор неактивности, если до этого была активность. В противном случае отправляется индикатор неактивности, даже если до этого не было активности.
Reset State on Restart	Если для параметра установлено значение true, то при запуске или перезапуске процессора начальное состояние всегда будет активным. В противном случае будет сохранено последнее состояние потока, о котором сообщалось.
Copy Attributes	Если установлено значение true, будут скопированы все атрибуты файла потока из файла потока, в котором возобновилась активность, во вновь созданный файл потока с индикаторами.
Monitoring Scope	Укажите способ определения активности потока. 'узел' означает, что активность проверяется на каждом узле отдельно. Это может быть полезно, если DFM ожидает, что каждый узел будет получать файлы потоков распределенным образом. Если выбрано значение «кластер», это означает, что поток активен, пока хотя бы один узел активно получает файлы потока. Если NiFi работает в автономном режиме, это значение должно быть установлено как «узел». Если выбрано значение «кластер», NiFi выводит предупреждение и работает в режиме «узел».
Reporting Node	Укажите, какой узел должен отправлять файлы потока уведомлений в неактивные и восстановленные отношения. Если выбрано значение «все», каждый узел в этом кластере отправляет файлы потока уведомлений. "основной" означает, что потоковые файлы будут отправляться только с основного узла. Если NiFi работает в автономном режиме, это значение должно быть установлено как "все", даже если оно "основное", NiFi будет действовать как "все".This Property is only considered if the [Monitoring Scope] Property has a value of "cluster".

Взаимосвязи

• inactive: Эта связь используется для передачи индикатора неактивности, когда ни один из FlowFiles не направляется в состояние «успех» в течение порогового времени
• success: Все входящие файлы Flow перенаправляются в раздел «Успех»
• activity.restored: Эта связь используется для передачи индикатора восстановления активности, когда FlowFiles направляются в состояние «успех» после периода неактивности