2

我有一个带有 nifi 的工作网络服务，在那里我得到一个 httprequest 并可以响应它。对于测试，我使用 ReplaceText 将特定内容添加到响应中。这可行，但我的目标是添加一个流文件（或它的值）作为 httpresponse 的内容。

用例是，我可以发送信息（来自 Kafka、HDFS 等）作为 httprequest（REST Web 服务）的响应。

我正在寻找和测试解决方案，但没有任何效果。是否可以使用 Apache NiFi (Hortonworks HDF) 的标准处理器？

最好的问候n3

4

1 回答 1

2

您应该能够通过 HandleHttpResponse 发回任何流文件的内容。例如，要创建一个从 HDFS 返回文件的 Web 服务，您应该能够执行以下操作：

HandleHttpRequest -> FetchHDFS -> HandleHttpResponse

您可能需要在 FetchHDFS 之前做更多的事情来操作数据，但这将是一般方法。关键是您需要一个接受传入流文件的处理器，因此对于 Kafka，您可以轻松地使用 PutKafka 做同样的事情，但不是 GetKafka，因为它不接受传入的流文件。

此 GitHub 存储库有一个从本地磁盘检索文件的 Web 服务示例：https ://github.com/bbende/nifi-streaming-examples

请参阅第一张图片，其中显示“处理日志级别请求”。

于 2016-06-02T12:06:35.573 回答