Notify 2025.10.2.19¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

Caches a release signal identifier in the distributed cache, optionally along with the FlowFile's attributes. Any flow files held at a corresponding Wait processor will be released once this signal in the cache is discovered.

标签¶

cache、distributed、map、notify、release、signal

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
attribute-cache-regex	Any attributes whose names match this regex will be stored in the distributed cache to be copied to any FlowFiles released from a corresponding Wait processor. Note that the uuid attribute will not be cached regardless of this value. If blank, no attributes will be cached.
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。

另请参阅¶

org.apache.nifi.processors.standard.Wait