NiFi如何从NiFi Flow查询内容存储库

Question

我有一个用例，我需要从另一个流程中使用FlowFile。

据我所知，所有流文件都保存在Content Repository中。

因此，例如，我的第一个流从DB读取数据，执行一些转换并输入Hive。

我的第二个流程需要获取那些已转换的流文件并将它们放到另一个地方或执行一些过滤等。

如何从NiFi流中的内容存储库中获取这些流文件？

Answer 1

您错了，流文件的内容将保存到内容存储库中。您不需要查询内容存储库以使用这些FlowFiles。我假设您使用的是PutHiveQL，因此只需使用success关系进行下一个流程。

示例：ExecuteSQL - >（成功）Transform Process Group - >（输出）PutHiveQL - >（成功） - >下一个流程

像这样的东西：