LookupRecord 2025.10.2.19¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
从记录中提取一个或多个字段，然后在 LookupService 中查找这些字段的值。如果 LookupService 返回结果，则可以选择将该结果添加到记录中。在这种情况下，处理器充当扩充处理器。无论如何，记录随后会路由到“matched”关系或“unmatched”关系（如果将“路由策略”属性配置为这样），表明 LookupService 是否返回了结果，从而允许处理器也充当路由处理器。用于在查找服务中查找值的“坐标”是通过添加用户定义的属性来定义的。添加的每个属性都将向“映射”中添加一个条目，其中该属性的名称成为“映射键”，RecordPath 返回的值成为该键的值。如果 RecordPath 返回多个值，则记录将被路由到“unmatched”关系（或“success”关系，具体取决于“路由策略”属性的配置）。如果一个或多个字段与“结果 RecordPath”匹配，则所有匹配的字段都将更新。如果配置的 LookupService 中没有匹配项，则不会更新任何字段。即，它不会用空值覆盖记录中的现有值。但是，请注意，如果您的架构（特别是为您的记录写入器配置的架构）中未考虑 LookupService 返回的结果，则不会将字段写入 FlowFile。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
根记录路径 |
指向 FlowFile 中每条顶层记录中的子记录的 RecordPath。如果指定，则将根据该子记录而非顶层记录评估其他 RecordPath 属性。这允许对单个顶层记录中的多个子记录进行扩充。 |
lookup-service |
用于在每条记录中查找值的查询服务 |
record-path-lookup-miss-result-cache-size |
Specifies how many lookup values/records should be cached. Setting this property to zero means no caching will be done and the table will be queried for each lookup value in each record. If the lookup table changes often or the most recent data must be retrieved, do not use the cache. |
record-reader |
指定用于读取传入数据的控制器服务 |
record-update-strategy |
此属性定义了使用查找服务返回的值更新记录时使用的策略。 |
record-writer |
指定用于写出记录的控制器服务 |
result-contents |
当获得包含记录的结果时，此属性决定记录本身是否插入到配置的路径中，或者记录的内容（即子字段）是否将插入配置的路径中。 |
result-record-path |
指向应使用查找服务返回的任何值来更新其值的字段的 RecordPath。如果未指定，则将忽略查找服务返回的值，除非需确定应将 FlowFile 路由到“matched”还是“unmatched”关系。 |
routing-strategy |
指定在查找完成后如何路由记录 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 FlowFile 无法扩充，则未更改的 FlowFile 将路由到此关系 |
success |
如果配置为这样，所有记录都将发送到此关系，除非出现故障 |
写入属性¶
名称 |
描述 |
|---|---|
mime.type |
将 mime.type 属性设置为记录写入器指定的 MIME 类型 |
record.count |
FlowFile 中的记录数 |