Apache NiFi是一个易于使用，功能强大且可靠的分布式系统，用于转换和分发数据。
如何通过MongoDB查询结果有条件地处理FlowFile？
我需要根据MongoDB查询的结果处理文件列表，但我找不到任何可以让我这样做的处理器。我基本上必须采取每个文件并处理它或完全...
我正在尝试从AVRO文件创建一个包含我的表结构的SQL表：{“type”：“record”，“name”：“warranty”，“doc”：“由Ki te生成的模式”，“字段” “：[{”......
我使用Nifi从远程服务器获取文件：我的文件如下：timestamp（ms），nodeID，值12345，x，12.4 12346，x，12.7 12348，x，13.4 12356，x，13,6 12355，y， 12.0我现在只是去取得......
我正在我的工作场所使用Docker运行Apache NiFi实例并使用代理。我把官方容器拉下来，旋转容器并将其设置为8081而不是8080 ...
对于我的生活，我无法进入NiFi Web UI。这让我讨厌安全。 TLDR;我找不到在Docker容器中启动NiFi并仍然访问UI的正确方法。这是我尝试过的（对...
我尝试将Avro文件转换为SQL请求。我的文件是这样的：{“type”：“record”，“name”：“warranty”，“doc”：“由Ki te生成的模式”，“fields”：[{“name”：“id”，“。 ..
有一个特定的处理器，如下所述，我感兴趣的是1.5.0中有一个额外的功能，而1.2.0，所以我想使用它。处理器名称：QueryDatabaseTable是......
Nifi QueryDatabaseTable处理器，何时会重置该值？
根据下面提到的文档，似乎我将重新启动处理器，它将重置我提供的最大列值的值，并将从头开始获取数据....
Avro在Docker Swarm中的所有服务的基本映像？ NiFi - > Kafka - > PostgreSQL
我是Docker的新手。也是NiFi和Kafka的新手......问题：如何使用Docker堆栈管理Avro？我是否为我在docker-compose.yml文件中构建的每个图像安装Avro？我应该单独...
想要获取文件并使用它的xml内容，然后更新其中一个标签，但更明显的错误ffstream = session（flowfile），后来关闭ffstream.close（）不关闭...
我一直在尝试将所有Apache NiFi日志重定向到stdout，将新的STDOUT appender配置到其./conf/logback.xml中。看起来像这样：
我是nifi新手。我试图创建一个震动规范，但没有得到它。有谁可以帮助我。详细信息如下：流文件中的属性：详细信息，ID，名称，地址，状态流文件......
Apache Nifi - 关于.Nar文件更改和Nifi重启
我想要我的申请建议：我在Nifi有多租户。对于每个流程组，我有不同的租户/用户。对于一个租户/用户的任何更改，例如他的自定义处理器（.nar文件...
我试图证明我的XML在Nifi上形成良好。我已经针对某些模式对其进行了验证，但有时我没有模式，所以希望确认它已经很好地形成了。但是所有的XML ......
我有一个带有一个输入和两个输出流的流程（快乐路径和故障路径）。我想测试流程，考虑将消息直接放到输入流并验证输出流。可能......
我的输入Json字段名包含破折号。例如：“Last-Name”：“Doe”当我将这个json传递给Infer Avro Schema处理器时，它没有告诉我“非法字符：姓氏”我也注意到了......
我有一个简单的问题，因为我是NiFi的新手。我有一个GetTwitter处理器设置和配置（假设正确）。我将Twitter端点设置为Sample Endpoint。我运行处理器，它......
NiFi：Wait-Notify无限期等待问题。查看分布式地图缓存的内容？
我正在测试等待通知工作流程，如图所示。我使用“$ {fragment.identifier}”作为WAIT和NOTIFY的“释放信号标识符”。 “信号计数器名称”是默认/空的。 “目标......
我使用EvaluateJsonPath从JSON中提取一个特定的值。我正在使用以下JSONPath表达式：$ .data [？（@。containerType =='SOURCE'&& @ .path =='SOURCE_KYLO_DATALAKE'）...
是否可以使用convertRecord或ant其他处理器处理null（CSV中不存在列）？我每天都有几个CSv文件。但是每个领域的问题并不相同......