如何使用 apache-nifi 映射来自两个流文件的数据答案

【问题标题】：How to map data from two flowfiles using apache-nifi如何使用 apache-nifi 映射来自两个流文件的数据
【发布时间】：2019-11-21 06:29:52
【问题描述】：

我有两个 apache-nifi 流。一个来自数据库，另一个来自 flowfile。

取自QueryDatabaseTableRecord 处理器。：

lat,long,location
232,3454,colombo
454,8834,kandy
438,94,galle

在我的流文件中，我有 lat 和 long 列。我想要的是比较来自两个流的lat 和long，如果匹配，则在流文件中添加一个新列location

我遇到的问题是（使用ExecuteScript），如何从两个流中获取值，因为它们具有相同的名称？

或者有没有办法使用另一个处理器来做到这一点？

【问题讨论】：

标签： csv apache-nifi

【解决方案1】：

尝试使用 DatabaseRecordLookupService 而不是 QueryDatabaseTableRecord 的 LookupRecord。您应该指定用户定义的属性 lat 到 /lat 和 long 到 /long 和 /location 的 Result RecordPath。如果流文件的 lat/long 与数据库行的 lat/long 匹配，它应该返回 location 的值。

【讨论】：