LookupRecord 2025.5.31.15¶
捆绑包¶
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 |
指定应缓存多少个查找值/记录。将此属性设置为零意味着不进行任何缓存，并且将查询表中每条记录中的每个查找值。如果查找表经常更改或必须检索最新数据，请不要使用缓存。 |
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 中的记录数 |