Apache NiFi是一个易于使用,功能强大且可靠的分布式系统,用于转换和分发数据。
我正在安装一个带有嵌入式zookeeper的三节点非安全nifi集群(1.5)。安装完成后,集群启动和选举完成,没有任何明显的问题。 ...
我的用例是这样的。我有一些X表从MySQL中提取。我正在使用SplitText拆分它们,将每个表放在一个单独的流文件中,并使用GenerateTableFetch和ExecuteSQL进行拉取....
GenerateTableFetch删除没有数据的flowfile以进行查询
我正在使用GenerateTableFetch与包含table_name的传入流文件来导入数据。我已经使用附加WHERE子句来处理使用...的updated_at列的增量更新
如何使用aws-java-sdk-ssm-1.11.68读取参数。不幸的是,我无法升级它,因为它被捆绑为NiFi的一部分。我的代码是自定义处理器的一部分。我看到的唯一选择......
我开始注意到这个错误,我的Nifi根本无法启动。 org.apache.nifi.web.server.JettyServer无法启动Web服务器...关闭。 org.apache.nifi.web.NiFiCoreException:无法...
我试图将硬编码值外部化到属性文件中,并在我的nifi工作流程中使用表达式语言语法。我用以下nifi.variable更新了nifi.properties ....
我试图使用风暴HDFS喷口,我有Apache Nifi将文件移动到风暴正在侦听的HDFS目录,但是一旦apache nifi开始移动文件,风暴就会感觉到并开始......
我经常使用GenerateFlowFile处理器来测试其他处理器的行为并理解流程。但每次,我忘记更改默认的“运行计划”,默认为“0”。 ...
NIFI处理器不会调用@OnStopped或@OnDisabled函数
我有一个NIFI-Processor,可以在OPC UA服务器上订阅一些标签。我很难找到终止订阅的方法。我的计划是让它继续运行,直到我决定停止......
获取系统的UUID并在NiFi FlowFile中更新为属性
有没有办法在NiFi中获取系统的唯一UUID(使用dmidecode生成)并将其设置为FlowFile的属性。
是否可以将Apache NiFi用作MS SQL Server数据库内计算的数据流引擎?
是否可以将Apache NiFi用作MS SQL Server数据库内计算的数据流引擎?换句话说,我想使用Apache NiFi就像我使用Alteryx一样。例如,我可以执行两个......
我可以单独使用Apache NiFi处理器模拟TCP客户端/服务器交互,还是必须为此编写代码?这里要考虑的处理器是ListenTCP,PutTCP和GetTCP。在......
根据我在使用NiFi构建一些数据库提取PoC后的理解,整个数据流作为流文件流运行。并且在任何特定时间,执行控制可以是一个或......
如何使用ConvertRecord和CSVRecordSetWriter在Apache NiFi中输出标题(没有数据)?
我正在使用Apache NiFi从数据库表中提取数据,并使用ConvertRecord使用AvroReader和CSVRecordSetWriter将获取的记录从avro更改为CSV文件。我的过程有效......
使用KafkaPublish处理器写入kafka主题时无法发送SSL关闭消息
我正在使用KafkaPublish处理器将消息发布到使用SASL_SSL安全协议保护的kafka主题(我们不使用Kerberos)。我收到以下错误:WARN无法发送SSL关闭...
Apache NiFi的InvokeHTTP和其他HTTP处理器是否会向重定向的URL发送授权标头?
如果我使用承载令牌配置了属性Authorization,那么InvokeHTTP会将该头发送到重定向的URL吗?我在文档中找不到任何关于它的内容。我似乎也不能......
我通过Apache NiFi传递使用OkHttp。我正在尝试确定如何在重定向上处理授权和其他敏感标头。 NiFi的InvokeHTTP唯一的互动......
我正在尝试获取ListHDFS处理的文件数,因此流程如下所示:ListHDFS - > UpdateAttribute - > LogAttribute我根据文档配置了UpdateAttribute(请参阅...
给定以下CSV输入文件:name,amount Abc,“1,234.56”Def,“2,222,222.222222”金额字段包含带逗号的十进制数字。如何将其解析为NiFi中的数字?我不想解析它......
我正在处理NiFi中的单个日志文件,以搜索包含特定字符串的记录,并将过滤后的记录传输到另一个文件。 (我正在使用GetFile-> SplitText-> RouteText-> MergeContent - > ...