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	Especifique como determinar a atividade do fluxo. “nó” significa que a atividade é examinada em nó individual separadamente. Pode ser útil se o DFM esperar que cada nó receba arquivos de fluxo de maneira distribuída. Com “cluster”, ele define que o fluxo está ativo enquanto pelo menos um nó recebe arquivos de fluxo ativamente. Se o NiFi estiver sendo executado no modo autônomo, isso deve ser definido como “nó”; se estiver em cluster, o NiFi registra uma mensagem de aviso e age como “nó”.
Nó de relatório	Especifique qual nó deve enviar arquivos de fluxo de notificação para relacionamentos inativos e activity.restored. Com “all”, todos os nós neste cluster enviam arquivos de fluxo de notificação. “Primary” significa que os arquivos de fluxo serão enviados apenas a partir de um nó primário. Se o NiFi estiver sendo executado no modo autônomo, isso deve ser definido como “all”, mesmo que seja “primary”, o NiFi atua como “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