Notify Processor
描述
在缓存中缓存释放信号标识符,可选择同时缓存 FlowFile 的属性。释放信号用于释放被 MergeContent 处理器持有的 FlowFile。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Release Signal Identifier | | 值,或属性表达式语言语句的结果,将针对 FlowFile 进行评估以确定发布信号缓存键 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Signal Counter Name | default | 值或属性表达式语言的结果,将针对 FlowFile 进行求值以确定信号计数器名称。信号计数器名称在相应的 Wait 处理器需要知道不同类型事件(如成功或失败)的出现次数或目标数据源名称等时非常有用。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Signal Counter Delta | 1 | 一个值,或属性表达式语言语句的结果,将 针对 FlowFile 进行求值以确定信号计数器增量。指定计数器应增加多少。例如,如果在上游流中以批处理方式处理了多个信号事件,可以使用此属性一次通知已处理的事件数量。零 (0) 有特殊含义,它将目标计数清除回 0,这在配合 Releasable FlowFile Count = 零 (0) 模式与 Wait 处理器使用时特别有用,可提供'开关门'类型的流控制。一 (1) 可以打开相应的 Wait 处理器,零 (0) 可以将其关闭,就像关门一样。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| 信号缓冲计数 | 1 | 指定在信号通知到缓存服务之前可以缓冲的传入 FlowFile 的最大数量。更多的缓冲可以提供更好的性能,因为它减少了与缓存服务的交互次数,当多个传入 FlowFile 共享相同的信号标识符时,按信号标识符分组信号。 | |
| Distributed Cache Service | | 控制器服务 API:AtomicDistributedMapCacheClientcn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 用于缓存释放信号的Controller Service,以便释放在相应等待处理器中排队的文件 |
| 属性缓存正则表达式 | | 名称匹配此正则表达式的任何属性将存储在分布式缓存中,以便复制到从相应的 Wait 处理器释放的任何 FlowFile。请注意,无论此值如何,uuid 属性都不会被缓存。如果为空白,则不缓存任何属性。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 当无法到达缓存时,或者释放信号标识符评估为 null 或空时,FlowFiles 将被路由到此关系 | 否 |
success | 释放信号已成功进入缓存的所有 FlowFiles 将被路由到此关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
notified | 所有 FlowFile 将具有 'notified' 属性。如果 FlowFile 已通知,此属性的值为 true,否则为 false。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。