如何将 apache nifi 流文件添加到 httpresponse
How to add a apache nifi flowfile into a httpresponse
我有一个使用 nifi 的工作网络服务，我在其中获得了一个 httprequest 并可以响应它。为了进行测试，我使用 ReplaceText 将特定内容添加到响应中。这可行，但我的目标是添加一个流文件（或它的值）作为 httpresponse 的内容。
用例是，我可以发送信息（来自 Kafka、HDFS 等）作为 httprequest（REST Web 服务）的响应。
我正在搜索和测试解决方案，但没有任何效果。是否可以使用 Apache NiFi (Hortonworks HDF) 的标准处理器？
此致
n3
您应该能够通过 HandleHttpResponse 发回任何流文件的内容。例如，要从 HDFS 创建 returns 文件的 Web 服务，您应该能够执行如下操作：
HandleHttpRequest -> FetchHDFS -> HandleHttpResponse
您可能需要在 FetchHDFS 之前做更多的事情来操作数据，但这是通用的方法。关键是您需要一个接受传入流文件的处理器，因此对于 Kafka，您可以轻松地使用 PutKafka 执行相同的操作，但不能使用 GetKafka，因为它不接受传入流文件。
此 GitHub 存储库有一个从本地磁盘检索文件的 Web 服务示例：https://github.com/bbende/nifi-streaming-examples
查看第一张图片 "Handle Request for Log Levels"。
我有一个使用 nifi 的工作网络服务，我在其中获得了一个 httprequest 并可以响应它。为了进行测试，我使用 ReplaceText 将特定内容添加到响应中。这可行，但我的目标是添加一个流文件（或它的值）作为 httpresponse 的内容。
用例是，我可以发送信息（来自 Kafka、HDFS 等）作为 httprequest（REST Web 服务）的响应。
我正在搜索和测试解决方案，但没有任何效果。是否可以使用 Apache NiFi (Hortonworks HDF) 的标准处理器？
此致 n3
您应该能够通过 HandleHttpResponse 发回任何流文件的内容。例如，要从 HDFS 创建 returns 文件的 Web 服务，您应该能够执行如下操作：
HandleHttpRequest -> FetchHDFS -> HandleHttpResponse
您可能需要在 FetchHDFS 之前做更多的事情来操作数据，但这是通用的方法。关键是您需要一个接受传入流文件的处理器，因此对于 Kafka，您可以轻松地使用 PutKafka 执行相同的操作，但不能使用 GetKafka，因为它不接受传入流文件。
此 GitHub 存储库有一个从本地磁盘检索文件的 Web 服务示例：https://github.com/bbende/nifi-streaming-examples
查看第一张图片 "Handle Request for Log Levels"。