从流文件内容中查询数据库记录以使用apache-nifi检索数据

Question

我的情况如下。从一个过程中，我从表中检索数据。

id,user_name
1,sachith
2,nalaka

我需要从account_details表中检索这些id的帐户详细信息。

我已经尝试使用各种与数据库相关的处理器。但是它们都不支持flowfile内容。

如何仅检索这些id的记录？

Answer 1

在下面使用：

ExecuteSQL( account_details) 
    -> convertAvroToJSON 
       -> EvaluateJsonPath 
           ->AttributesToJson 

（（这里您仅接受ID并忽略测试）

Answer 2

使用LookupRecord控制器服务查看DatabaseRecordLookupService。那应该允许您使用id字段从数据库中查找其他字段并将其添加到传出记录中。这是一种常见的“丰富”模式，其中可以针对数据库，CSV文件等进行查找。