如何使用NiFi ExecuteScript处理器与Python？
我在Apache NiFi中使用ExecuteScript处理器，采用一个简单的Python脚本（保存为.py文件）。在处理器的属性中，我将脚本引擎设置为python，并将脚本文件设置为此脚本的路径。import time count = 0 while(count < 20): ...
我如何查看处理器的FlowFile或标准输出(STDOUT)？
当事情失败时，我想查看流文件或有问题的处理器的输出（stdout+stderr）。是否有一种简单的方法可以转储所有Flowfile的属性，或者只是浏览Flowfile？
NIFI的使用案例
我有一个关于Nifi以及它的能力和适当使用场景的问题。 我已经读到过Nifi的目标是创建一个允许基于流程的处理的空间。在玩弄了一下Nifi之后，我也意识到了它模拟/塑造数据的能力，这对我非常有用。可以说Nifi也可以用于数据建模吗？ 谢谢！
创建自定义处理器时出现错误，Apache NiFi。
我试图使用mvn clean package命令构建NiFi自定义处理器的包，但我得到了以下输出:[INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILU...
为时间戳记录创建适当的Avro模式
我想知道将某些格式为JSON的数据转换为Avro所需的正确Avro模式应该是什么：{"entryDate": "2018-01-26T12:00:40.930"} 我的架构：{ "type" : "record", "name" : "schema", "fields"...
Apache NiFi ExecuteScript：使用映射文件替换Json值的Groovy脚本
我正在使用Apache NiFi 0.5.1和Groovy脚本一起工作，以便将传入的Json值替换为包含在映射文件中的值。 映射文件看起来像这样（它是一个简单的 .txt 文件）：Header1;Header2;Header3 A;some text;A2 我已经开始了以下内容：import...
Apache NiFi的开发生命周期
我了解到在 NiFi 中，正如他们的文档所定义的那样，“连续改进在生产中发生”。这使它不适合作为传统的开发工具。但是对于我正在处理的项目，我们已决定使用这个工具，因此我不想争论它的优点，因为我知道会有一些问题。 例如，如果我将更改推送到现有环境（从暂存到生产），并且目标位置存在实时编辑，则它...
Kafka Avro 消费者存在解码问题
当我试图在使用我的相应模式的数据上运行Kafka Consumer with Avro时，它返回了一个错误"AvroRuntimeException：Malformed data. Length is negative: -40"。 我看到其他人也遇到了类似的问题转换字节数组为JSON, Av...
从InvokeHTTP POST获取响应
第一次使用NiFi！ 我正在使用InvokeHTTP nifi处理器（使用此链接作为示例来实现我的流程http://www.tomaszezula.com/2016/10/30/nifi-and-http-post-configuration/）。我目前需要进行POST以对我正在使用的服务器...
APACHE NIFI与APACHE AIRFLOW与APACHE FALCON之间的比较？在下面的情况下哪个最适合？
我正在使用Java开发一个解决方案，通过REST API与属于不同供应商的一组设备进行通信。因此，对于每个供应商，我都需要在我的解决方案中执行一系列过程。然而，这些过程将根据每个供应商的不同而改变。以下是需要执行的高级过程。 - 从文件夹中检索XML文件 - 处理XML文件 - 执行一些图像...