EnrichAttributes 2025.5.31.15

捆绑包

com.snowflake.openflow.runtime | runtime-enrichment-nar

描述

使用配置的 Lookup Service 查找一个值,并将结果作为一个或多个属性添加到 FlowFile 中。通常,它与 DatabaseLookup 服务配合使用,用于通过查询数据库丰富 FlowFile 的信息,并将查询结果添加为属性。

标签

attributes、database、enrichment、json、lookup、openflow

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

属性名称

要添加的属性的名称,其内容将是 Lookup Service 返回的 Record 的 JSON 表示。

属性前缀

添加到所有属性名称前的前缀。

展平化策略

当从查找服务返回一个记录时,此属性指定应如何将记录展平化为多个 FlowFile 属性

Lookup Service

用于丰富信息的 Lookup Service

关系

名称

描述

failure

如果由于任何原因无法增强 FlowFile,则该 FlowFile 将路由到此关系。

matched

那些通过 Lookup Service 成功获取 Record 并丰富了自身信息的 FlowFiles 将路由到此关系。

unmatched

Lookup Service 未找到匹配项的 FlowFiles 将路由到此关系。

用例

根据 FlowFile 的属性查询数据库,以检索信息。

另请参阅

语言: 中文