MonitorActivity 2025.5.31.15¶

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. “node” significa que a atividade é examinada em um nó individual separadamente. Isso pode ser útil se o DFM espera que cada nó receba FlowFiles de forma distribuída. Com “cluster”, define-se que o fluxo está ativo enquanto pelo menos um nó recebe FlowFiles ativamente. Se o NiFi estiver em execução no modo autônomo, isso deve ser definido como “node”; se for “cluster”, o NiFi registrará uma mensagem de aviso e atuará como escopo de “node”.
Nó de relatório	Especifique qual nó deve enviar FlowFiles de notificação para as relações inactive e activity.restored. Com “all”, todos os nós desse cluster enviam FlowFiles de notificação. “primary” significa que os FlowFiles serão enviados somente de um nó primário. Se o NiFi estiver sendo executado no modo autônomo, isso deverá ser definido como “all”; mesmo que seja “primary”, o NiFi atuará 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
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.
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.

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