Notify

文档中心 › 组件索引 › Notify

Notify Processor

类型全限定名:cn.org.acal.lynxus.processors.standard.Notify

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

在缓存中缓存释放信号标识符,可选择同时缓存 FlowFile 的属性。释放信号用于释放被 MergeContent 处理器持有的 FlowFile。

标签

mapcachenotifydistributedsignalrelease

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
Release Signal Identifier值,或属性表达式语言语句的结果,将针对 FlowFile 进行评估以确定发布信号缓存键
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Signal Counter Namedefault值或属性表达式语言的结果,将针对 FlowFile 进行求值以确定信号计数器名称。信号计数器名称在相应的 Wait 处理器需要知道不同类型事件(如成功或失败)的出现次数或目标数据源名称等时非常有用。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Signal Counter Delta1一个值,或属性表达式语言语句的结果,将 针对 FlowFile 进行求值以确定信号计数器增量。指定计数器应增加多少。例如,如果在上游流中以批处理方式处理了多个信号事件,可以使用此属性一次通知已处理的事件数量。零 (0) 有特殊含义,它将目标计数清除回 0,这在配合 Releasable FlowFile Count = 零 (0) 模式与 Wait 处理器使用时特别有用,可提供'开关门'类型的流控制。一 (1) 可以打开相应的 Wait 处理器,零 (0) 可以将其关闭,就像关门一样。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
信号缓冲计数1指定在信号通知到缓存服务之前可以缓冲的传入 FlowFile 的最大数量。更多的缓冲可以提供更好的性能,因为它减少了与缓存服务的交互次数,当多个传入 FlowFile 共享相同的信号标识符时,按信号标识符分组信号。
Distributed Cache Service控制器服务 API:
AtomicDistributedMapCacheClient
cn.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)

该组件不受限。

输入要求

该组件要求有传入连接。