Notify 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
在分布式缓存中缓存版本信号标识符，也可以缓存 FlowFile 的属性。 一旦发现缓存中的该信号，保存在相应等待处理器中的任何 FlowFile 都将被释放。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
attribute-cache-regex |
名称与该正则表达式匹配的任何属性都将存储在分布式缓存中，以便复制到相应等待处理器释放的任何 FlowFiles 中。 请注意，无论这个值如何，uuid 属性都不会被缓存。 如果为空，则不会缓存任何属性。 |
distributed-cache-service |
控制器服务，用于缓存释放信号，以便释放在相应等待处理器上排队的文件 |
release-signal-id |
一个值或属性表达式语言语句的结果，将根据 FlowFile 进行评估，以确定释放信号缓存键 |
signal-buffer-count |
指定在收到通知服务缓存信号之前可缓存的传入 FlowFile 的最大数量。缓冲区越多，可提供的性能越高，因为当多个传入 FlowFile 共享相同的信号标识符时，它会按信号标识符对信号进行分组，以减少与缓存服务的交互次数。 |
signal-counter-delta |
一个值或属性表达式语言语句的结果，将根据 FlowFile 进行评估，以确定信号计数器增量。指定计数器应增加多少。例如，如果在上游流中以批处理方式处理多个信号事件，则可以使用此属性立即通知已处理的事件数量。零 (0) 具有特殊含义，它将目标计数清除回 0，这在与 Wait Releasable FlowFile Count = Zero (0) 模式一起使用时特别有用，可提供“open-close-gate”类型的流控制。一 (1) 可以打开相应的等待处理器，零 (0) 可以像关闭大门一样，起否定作用。 |
signal-counter-name |
一个值或属性表达式语言语句的结果，将根据 FlowFile 进行评估，以确定信号计数器名称。当相应等待处理器需要知道不同类型的事件（例如成功或失败）的发生次数或目标数据源名称等时，信号计数器名称很有用。 |
关系¶
名称 |
描述 |
|---|---|
failure |
当无法到达缓存，或者释放信号标识符的计算结果为 null 或空时，FlowFiles 将路由到此关系 |
success |
成功将释放信号输入到缓存中的所有 FlowFiles 都将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
notified |
所有 FlowFiles 都会有“notified”属性。此属性的值为 True，即已通知 FlowFile，否则为 False。 |