【发布时间】：2016-11-17 04:49:46
【问题描述】：
我正在尝试使用 Apache NiFi 创建 Web 服务数据流。我已经设置了请求和响应 http 处理器，但是我似乎无法弄清楚如何使用来自另一个连接的数据从请求处理器更新流文件。有人可以告诉我如何实现这种行为吗？
【问题讨论】：
标签： web-services dataflow apache-nifi
【发布时间】：2016-11-17 04:49:46
【问题描述】：
您需要一个可以接收传入流文件并将内容替换为结果的处理器。一个例子是 ExecuteSQL 处理器，它将用查询数据库的结果（Avro 格式）替换传入流文件的内容。所以一个 HandleHttpRequest -> ExecuteSQL -> HandleHttpResponse 的流程。
一个问题是，许多从某处检索数据的处理器并不意味着接收传入的流文件。例如，GetSolr、GetHBase 和许多其他 Get 处理器等处理器本身就是源处理器。
【讨论】：
-
嗨，布莱恩。是的，一些处理器不打算接受传入连接的事实是我的问题。我需要构建一个位于 HandleHttpRequest 和 HandleHttpResponse 处理器之间的自定义处理器。此自定义处理器将能够接受第二个传入连接，并且其流文件将用于替换第一个连接中流文件的内容。一种连接“查找”处理器。我会尝试这个并在 github 上提供它。