FetchDistributedMapCache

文档中心 › 组件索引 › FetchDistributedMapCache

FetchDistributedMapCache Processor

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

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

描述

从 FlowFile 属性计算缓存键,对于每个传入 FlowFile,并从与每个键关联的映射缓存中获取值。

标签

mapcachefetchdistributed

属性

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

名称默认值可选值描述
Cache Entry Identifier${hash.value}FlowFile 属性的逗号分隔列表,或属性表达式语言语句的结果,将针对 FlowFile 进行求值,以确定用于标识重复项的值;这些值将被缓存。注意:除非指定了“将缓存值放入属性”,否则只允许单个缓存条目标识符。仅当目标是一组属性时才支持多个缓存查找(有关命名约定等详细信息,请参阅“将缓存值放入属性”的文档)。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Distributed Cache Service控制器服务 API:
DistributedMapCacheClient
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
用于获取缓存值的Controller Service。
Put Cache Value In Attribute如果设置,接收到的缓存值将被放入 FlowFile 的属性中,而不是 FlowFile 的内容中。要放入的属性键通过求值此属性的值来确定。如果选择了多个缓存条目标识符,将写入多个属性,使用此属性的求值值,后跟句点 (.) 和缓存条目标识符的名称。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
属性最大长度256如果将缓存值路由到 FlowFile 的属性(通过设置 "Put Cache Value in attribute" 属性),放入属性值的字符数最多不超过此值。这很重要,因为属性保存在内存中,过大的属性会很快导致内存溢出问题。如果输出超过此值,将被截断以适配。建议尽可能设置较小的值。
Character SetUTF-8对缓存值进行编码的字符集。 仅当路由到属性时才会使用它。

关系 (Relationships)

名称描述自动终止
failure如果无法与缓存通信或者缓存条目被评估为空,则 FlowFile 将受到惩罚并路由到此关系否
not-found如果在缓存中没有找到 FlowFile 的缓存条目标识符,它将被路由到此关系否
success如果与缓存通信成功,它将被路由到此关系否

写入的 FlowFile 属性

名称描述
user-defined如果设置了'将缓存值放入属性'属性,则其设置值将成为属性键,而值将是 Map Cache 的响应内容。如果选择了多个缓存条目标识符,将使用此属性的计算值加上句点(.)和缓存条目标识符的名称写入多个属性。例如,如果缓存条目标识符属性设置为 'id,name',且用户定义属性名为 'fetched',则将写入两个属性 fetched.id 和 fetched.name,包含各自的值。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。