MonitorActivity 2025.10.2.19¶

Pacote¶

org.apache.nifi | nifi-standard-nar

Descrição¶

Monitora a atividade do fluxo e envia um indicador quando o fluxo não tem dados por um período de tempo especificado e novamente quando a atividade do fluxo é restaurada

Tags¶

active, activity, detection, flow, inactive, monitor

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Mensagem de atividade restaurada	A mensagem que será o conteúdo dos FlowFiles que é enviada à relação “activity.restored”
Enviar mensagens continuamente	Se verdadeiro, enviará o indicador de inatividade continuamente a cada período de tempo da duração limite até que a atividade seja restaurada; se falso, enviará um indicador somente quando o fluxo ficar inativo pela primeira vez
Copiar atributos	Se verdadeiro, copiará todos os atributos do FlowFile que retomou a atividade para o FlowFile indicador recém-criado
Mensagem de inatividade	A mensagem que será o conteúdo dos FlowFiles enviada à relação “inactive”
Escopo de monitoramento	Specify how to determine activeness of the flow. “node” means that activeness is examined at individual node separately. It can be useful if DFM expects each node should receive flow files in a distributed manner. With “cluster”, it defines the flow is active while at least one node receives flow files actively. If NiFi is running as standalone mode, this should be set as “node”, if it “s” cluster “, NiFi logs a warning message and act as” node’scope.
Nó de relatório	Specify which node should send notification flow-files to inactive and activity.restored relationships. With “all”, every node in this cluster send notification flow-files. “primary” means flow-files will be sent only from a primary node. If NiFi is running as standalone mode, this should be set as “all”, even if it “s” primary “, NiFi act as” all”.
Redefinir estado ao reiniciar	Quando o processador for iniciado ou reiniciado, se definido como verdadeiro, o estado inicial estará sempre ativo. Caso contrário, o último estado de fluxo relatado será preservado.
Duração do limite	Determina quanto tempo deve transcorrer antes de considerar o fluxo como inativo
Aguardar a atividade	Quando o processador for iniciado ou reiniciado, se definido como verdadeiro, somente enviará um indicador de inatividade se tiver havido atividade anteriormente. Caso contrário, envie um indicador inativo, mesmo que não tenha havido atividade anteriormente.

Gerenciamento do estado¶

Escopos	Descrição
LOCAL	MonitorActivity armazena o último carimbo de data/hora em cada nó como estado, para que possa examinar a atividade em todo o cluster. Se “Copiar atributo” for definido como verdadeiro, os atributos do FlowFile também serão mantidos. No escopo local, ele armazena o último carimbo de data/hora da atividade conhecida se o fluxo estiver inativo.
CLUSTER	MonitorActivity armazena o último carimbo de data/hora em cada nó como estado, para que possa examinar a atividade em todo o cluster. Se “Copiar atributo” for definido como verdadeiro, os atributos do FlowFile também serão mantidos. No escopo local, ele armazena o último carimbo de data/hora da atividade conhecida se o fluxo estiver inativo.

Relações¶

Nome	Descrição
activity.restored	Essa relação é usada para transferir um indicador de Atividade restaurada quando os FlowFiles estão sendo roteados para “sucess” após um período de inatividade
inactive	Essa relação é usada para transferir um indicador de inatividade quando nenhum dos FlowFiles é roteado para “success” por um período de tempo de duração limite
success	Todos os FlowFiles de entrada são encaminhadas para “success”

Grava atributos¶

Nome	Descrição
inactivityStartMillis	A hora em que a inatividade começou, na forma de milissegundos desde a época
inactivityDurationMillis	O número de milissegundos da duração da inatividade