ControlRate 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Controla a taxa na qual os dados são transferidos para os processadores subsequentes. Se você configurar um uma duração de tempo curta, a precisão do controle de fluxo ficará pior. Você pode melhorar essa precisão diminuindo a duração de rendimento, às custas de mais tarefas dadas ao processador.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Atributo de agrupamento |
Por padrão, um único “controle de fluxo” é usado para todos os FlowFiles. Se esse valor for especificado, um controle de fluxo separado será usado para cada valor especificado pelo atributo com esse nome. A alteração desse valor redefine os contadores de taxas. |
Taxa máxima de dados |
A taxa máxima na qual os dados devem passar por esse processador. Espera-se que o formato dessa propriedade seja um tamanho de dados (como “1 MB”) representando bytes por duração de tempo. |
Taxa de FlowFile máxima |
A taxa máxima na qual FlowFiles devem passar por esse processador. Espera-se que o formato dessa propriedade seja um número inteiro positivo representando uma contagem de FlowFiles por tempo de duração |
Taxa máxima |
A taxa máxima na qual os dados devem passar por esse processador. Espera-se que o formato dessa propriedade seja um número inteiro positivo ou um tamanho de dados (como “1 MB”) se os critérios de controle de taxa estiverem definidos como “taxa de dados”. |
Critérios de controle de taxa |
Indica os critérios usados para controlar a taxa de transferência. A alteração desse valor redefine os contadores de taxas. |
Atributo controlado por taxa |
O nome de um atributo cujos valores se acumulam no limite da taxa se os critérios de controle de taxa forem definidos como “valor de atributo”. O valor de atributo referenciado por essa propriedade deve ser um long positivo, ou o FlowFile será encaminhado para falha. Esse valor é ignorado se os critérios de controle de taxa não estiverem definidos como “valor de atributo”. A alteração desse valor redefine os contadores de taxas. |
Estratégia para taxa excedida |
Especifica como lidar com uma FlowFile de entrada quando a taxa máxima de dados tiver sido excedida. |
Duração |
O período de tempo ao qual a tarifa máxima se refere. A alteração desse valor redefine os contadores de taxas. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
FlowFiles serão encaminhados para essa relação se estiver faltando um atributo controlado por taxa necessário ou se o atributo não estiver no formato esperado |
success |
FlowFiles são transferidos para essa relação em condições normais |
Casos de uso¶
Limite a taxa na qual os dados são enviados para um sistema downstream com poucos ou nenhum pico |
Limite a taxa de envio de FlowFiles para um sistema downstream com poucos ou nenhum pico |
Rejeite solicitações que excedam uma taxa específica com pouco ou nenhum pico |
Rejeite solicitações que excedam uma taxa específica, permitindo picos |