ControlRate 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
控制数据传输到后续处理器的速率。如果配置了非常短的时间间隔，限流的准确性将会降低。您可以通过缩短等待时间来提升准确性，但这会导致处理器接收更多任务。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
分组属性 |
默认情况下，一个“限流”将用于所有 FlowFiles。如果指定了此值，则对具有此名称的属性指定的每个值都将使用单独的限流。更改此值会重置速率计数器。 |
最大数据速率 |
数据通过该处理器的最大速率。此属性的格式应为数据大小（例如“1 MB”），表示每个时间间隔的字节数。 |
Maximum FlowFile Rate |
FlowFiles 通过该处理器的最大速率。此属性的格式应为正整数，表示每个时间间隔的 FlowFiles 计数 |
最大速率 |
数据通过该处理器的最大速率。如果速率控制标准设置为“数据速率”，则此属性的格式应为正整数或数据大小（例如“1 MB”）。 |
速率控制标准 |
表示用于控制吞吐率的标准。更改此值会重置速率计数器。 |
限速属性 |
如果速率控制标准设置为“属性值”，则为逐渐增加到速率限制的值的属性名称。此属性引用的属性的值必须为正整数长整型，否则 FlowFile 将路由到 failure。如果速率控制标准未设置为“属性值”，则此值将被忽略。更改此值会重置速率计数器。 |
超过速率策略 |
指定在超过最大数据速率时如何处理传入的 FlowFile。 |
时间间隔 |
与最大速率相关的时间量。更改此值会重置速率计数器。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 FlowFiles 缺少必要的限速属性，或属性的格式不符合预期，则会被路由到此关系 |
success |
FlowFiles 在正常条件下会被传输到此关系 |
用例¶
限制数据发送到下游系统的速率，尽量避免突发流量 |
限制 FlowFiles 发送到下游系统的速率，尽量避免突发流量 |
拒绝超出特定速率的请求，尽量避免突发流量 |
拒绝超出特定速率的请求，允许突发流量 |