如何将来自外部 JSON 的属性添加到 FlowFile

How to add attributes from external JSON to a FlowFile

需要帮助的人。

我有两个文件应该一起解析成一个流文件:

  1. 应该是流文件内容的csv文件。
  2. 一个JSON应该是流文件属性的文件。

如何在不借助脚本的情况下在 NiFi 中执行此操作?

逻辑是:

1 - GetFile(您阅读 Json)

2 - 从 Json

获取属性

3 - 将文件名属性设置为您的 csv 文件

4 - 获取 csv 文件(直接进入流内容)

您的流程应该如下所示:

我已经为这个用例创建了一个示例模板:

http://www.aodba.com/apache-nifi-template-integrate-multiple-files-single-flow-2/