在Apache NiFi中，我在适当的范围内创建了一个控制器。现在我想在其他地方使用相同的控制器。我的问题是，我可以将作用域更改为当前处理器组的祖先，以便其他处理器组可以使用它吗？ 谢谢。

初次使用Nifi！ 我想知道在Nifi中是否有一种方法可以使用"PutFile"处理器，并将其写入一个单独的文件，而不是创建多个不同的文件？是否需要使用另一个处理器来实现这一点？

我希望使用MergeContent处理器将推文合并为批量插入到Elasticsearch索引中。为此，我需要将命令和每个推文分别用\n分隔开来。 以下是应该看起来的样子： { action: { metadata }}\n { request body }\n 这将会是 ...

我们正在努力尝试找到在开发、测试和生产阶段中流程进展时更新处理器配置的最佳方法。我们真的很想避免在将流程部署到特定环境时操纵处理器中的主机、端口等引用。至少在我们的情况下，对于像ElasticSearch、PostGres等东西，我们将有不同的主机。其他人是如何处理这个问题的？ 我们考虑过以...

我希望将Nifi的流文件发送到Spark中，并在Spark中进行一些转换，然后再将结果发送回Nifi，以便我可以在Nifi中进行进一步操作。我不想将流文件写入数据库或HDFS，然后触发Spark作业。我想直接将流文件发送到Spark，并直接从Spark接收结果返回到Nifi。我尝试使用Nifi...

在图像中，有3个连接到LogAttribute处理器的GenerateFlowFile处理器。我想知道漏斗的作用。请澄清。 我理解漏斗的一种用途是将来自两个不同过程组的组件合并，如youtube视频所述。

背景 我有一个工作流程，使用FetchFile处理器、一些中间处理器（例如RouteOnAttribute、HashContent等），然后是一个PutFile处理器。 在整个过程中，内容未被操纵。 问题 PutFile处理器使用时间戳而不是原始文件名保存文件。 问题 如何实现以下...

我遇到了一个问题，就是NIFI服务无法启动。我监视了nifi-app.log，并发现它显示OutOfMemory错误。我在bootstap.conf文件中增加了内存，但错误仍然存在。 附上nifi-app.log文件。 2017-12-19 17:08:37,133 ERROR [...

在NiFi中，存在一种数据流从MQTT（ConsumeMQTT）获取数据并发布到HDFS路径（PutHDFS）。我需要在将消费的数据推送到HDFS路径之前引入60分钟的延迟。发现ControlRate和MergeContent处理器可能是可行的解决方案，但不确定哪个更好。 引入时间延迟的理...

我想知道是否可以将flowfile大小用作routeOnAttribute的参数，我想要创建这样的表达式： ${filename.fileSize>500} 但它告诉我表达式应该返回true，而我的表达式返回字符串，我应该怎么做才能在routeOnAttribute中创建新连接（p...