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

【问题标题】：Querying a database record from flowfile content to retrive data using apache-nifi使用 apache-nifi 从流文件内容中查询数据库记录以检索数据
【发布时间】：2019-12-18 08:37:23
【问题描述】：

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

id,user_name
1,sachith
2,nalaka

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

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

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

【问题讨论】：

标签： mysql apache-nifi

【解决方案1】：

在下面使用：

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

（这里只取id，忽略test）

【讨论】：

【解决方案2】：

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

【讨论】：

您能举例说明一下吗？

【解决方案3】：

您可以使用 QueryRecord 处理器从流文件中查询数据。您需要在此处理器中设置读取器和写入器才能正确打开文件并进行写入。要创建查询，您必须使用查询名称创建一个属性，并将查询本身作为该属性的值。之后，您可以为此属性创建一个输出流。

查询语法为Apache Calcite。你可以找到进一步的解释here

【讨论】：