FetchDistributedMapCache Processor
描述
从 FlowFile 属性计算缓存键,对于每个传入 FlowFile,并从与每个键关联的映射缓存中获取值。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| Cache Entry Identifier | ${hash.value} | FlowFile 属性的逗号分隔列表,或属性表达式语言语句的结果,将针对 FlowFile 进行求值,以确定用于标识重复项的值;这些值将被缓存。注意:除非指定了“将缓存值放入属性”,否则只允许单个缓存条目标识符。仅当目标是一组属性时才支持多个缓存查找(有关命名约定等详细信息,请参阅“将缓存值放入属性”的文档)。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Distributed Cache Service | | 控制器服务 API:DistributedMapCacheClientcn.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 Set | UTF-8 | 对缓存值进行编码的字符集。 仅当路由到属性时才会使用它。 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 如果无法与缓存通信或者缓存条目被评估为空,则 FlowFile 将受到惩罚并路由到此关系 | 否 |
not-found | 如果在缓存中没有找到 FlowFile 的缓存条目标识符,它将被路由到此关系 | 否 |
success | 如果与缓存通信成功,它将被路由到此关系 | 否 |
写入的 FlowFile 属性
| 名称 | 描述 |
|---|---|
user-defined | 如果设置了'将缓存值放入属性'属性,则其设置值将成为属性键,而值将是 Map Cache 的响应内容。如果选择了多个缓存条目标识符,将使用此属性的计算值加上句点(.)和缓存条目标识符的名称写入多个属性。例如,如果缓存条目标识符属性设置为 'id,name',且用户定义属性名为 'fetched',则将写入两个属性 fetched.id 和 fetched.name,包含各自的值。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。