如何将来自外部 JSON 的属性添加到 FlowFile
How to add attributes from external JSON to a FlowFile
需要帮助的人。
我有两个文件应该一起解析成一个流文件:
- 应该是流文件内容的csv文件。
- 一个JSON应该是流文件属性的文件。
如何在不借助脚本的情况下在 NiFi 中执行此操作?
逻辑是:
1 - GetFile(您阅读 Json)
2 - 从 Json
获取属性
3 - 将文件名属性设置为您的 csv 文件
4 - 获取 csv 文件(直接进入流内容)
您的流程应该如下所示:
我已经为这个用例创建了一个示例模板:
http://www.aodba.com/apache-nifi-template-integrate-multiple-files-single-flow-2/
需要帮助的人。
我有两个文件应该一起解析成一个流文件:
- 应该是流文件内容的csv文件。
- 一个JSON应该是流文件属性的文件。
如何在不借助脚本的情况下在 NiFi 中执行此操作?
逻辑是:
1 - GetFile(您阅读 Json)
2 - 从 Json
获取属性3 - 将文件名属性设置为您的 csv 文件
4 - 获取 csv 文件(直接进入流内容)
您的流程应该如下所示:
我已经为这个用例创建了一个示例模板:
http://www.aodba.com/apache-nifi-template-integrate-multiple-files-single-flow-2/