我目前正在处理一个NiFi流，它需要实现自定义处理器来对csv记录应用转换。由于错误不能用单个线程再现，所以我更多地考虑处理流文件时的一些问题，或者我不知道的NiFi的某些方
浏览 4提问于2016-09-21得票数 1
回答已采纳
我试图将原始的流文件作为输入发送到下一个处理器，但最终得到了错误，我对Nifi非常陌生，也对Java有一些经验。
浏览 22提问于2020-04-15得票数 0
回答已采纳
我使用nifi创建了一个tweet流，并在solr中对它们进行了分析，但是tweet进入nifi，但没有任何东西发生在nifi处理器中的solr.But错误putsolrcontentstream无法连接到本地主机Putsolrcontentstream处理器错误：
浏览 0提问于2016-11-24得票数 0
变量注册表属性是为了促进软件开发生命周期而添加到Nifi中的功能。这意味着您可以在单独的开发环境中开发流，并利用nifi.variable.registry.properties属性中指定的自定义属性文件以及表达式语言来使用处理器配置中的变量。然后，您可以将流作为模板与自定义属性文件一起导出，并将其推送到生产环境中。但是，一旦启动了Nifi的生产实例，就不可能修改您的自定义
浏览 11提问于2017-02-03得票数 4
回答已采纳
我需要获得文件创建时间，这需要存储在数据库中。我用的是执行器处理器。flowFile.getAttribute('file.creationTime')返回null。知道如何获取流文件的file.creationTime属性值吗？
浏览 0提问于2018-08-22得票数 0
回答已采纳
我们有多个团队nifi应用程序在同一台nifi机器上运行...有没有办法记录特定于我的应用程序的日志？另外，在默认情况下，nifi-app.log文件很难跟踪问题，公告牌仅在5分钟内显示错误消息...如何在Nifi中捕获错误并发送邮件警报？
请帮我解决这个问题。提前感谢！
浏览 10提问于2019-03-30得票数 3
1回答
如果是的话，nifi是否有可能使用哪种处理器？特别是java程序的执行，因为我已经看到卡桑德拉的处理器已经存在了。
谢谢!
浏览 3提问于2017-05-16得票数 2
回答已采纳
1回答
我已经开发了一个用于HDFS中数据摄取的NiFi流原型。现在我想要提高整体表现，但我似乎真的无法向前迈进。
流接收输入csv文件(每行有80个字段)，在行级别拆分它们，将一些转换应用到字段(使用4个自定义处理器依次执行)，将新行缓冲到csv文件中，并将它们输出到HDFS中。我开发处理器的方式是，在读取每个记录并将其字段移动到flow文件属性时，只访问流文件的内容一次。在amaz
浏览 4提问于2016-09-27得票数 5
回答已采纳
几天前，我陷入了问题(这涉及自定义nifi处理器的错误行为)。调试对我没有帮助。因此，我决定探索nifi模拟框架(我应该已经这样做了，但没有这么做:)，正如关于这个问题的评论中所建议的那样。我正在接受这些链接的帮助：，
我想要做的是将单个流文件发送到自定义处理器。为此，我按照建议使用MergeContent (带有FlowFile v3版本)和PutFile处理器保存/序列化了实际的流<e
浏览 2提问于2019-05-03得票数 0
回答已采纳
1回答
我正在尝试使用配置文件自定义kylo中可用的标准数据摄取模板。我在kylo/conf目录中的application.properties文件中添加了字段名nifi.getfile.business_line1=Test。当我试图在处理器${ business_line1 }中使用nifi表达式时，它将抛出为“business_line1未找到”。
或者，还有其他方法来提供自定义标准数据吗？
浏览 3提问于2017-08-16得票数 3
回答已采纳
我正在尝试获取一个容器化的Nifi实例，以便使用Active作为一个流文件源。我希望定期对AD运行一个查询(例如LDAP查询)，并将特定用户的列表返回给Nifi，以便为每个用户在磁盘上创建一个文件夹。
我查看了处理器列表，没有发现任何似乎适合查询AD的东西。
浏览 1提问于2020-09-01得票数 1
回答已采纳
我有一个本地NiFi流，它在本地读取文件，并通过cmd行参数将其输入python。但是，我现在希望NiFi读取存储在Amazon S3中的其他文件，并将它们输入到我的python脚本中。我使用了ListS3和FetchS3处理器来获取我的文件，并且我可以访问像s3.bucket和filename这样的变量，这些变量与存储在S3中的文件完全匹配。我还使用MergeContent合并来
浏览 3提问于2017-02-02得票数 2
回答已采纳
我想为nifi处理器创建日志文件，我让它们形成tailFail并逐行拆分文本，然后检查是否是错误、信息或警告日志，并路由到可执行文件处理器，但此时我有5个流文件，我想统一这个拆分的流文件并将其写入一个流文件中我还想知道nifi自定义日志是否返回了我在工作流程中添加的所有处理器的日志文件，以及是否在logback
浏览 2提问于2017-08-31得票数 0
回答已采纳
我目前的理解是，NiFi处理器属性是特定于该处理器的。因此，向处理器添加新属性只会在该处理器中可见，而不会传递给以后的处理器块？这就是为什么UpdateAttribute必须添加在流文件遍历数据流时与其保持在一起的元数据：那么，允许用户在处理器中添加自定义属性(而不是为该处理器执行所需的属性)有什么价值呢？它是否类似于创建变量，然后可以用于其他属性？
浏览 1提问于2019-01-19得票数 6
回答已采纳
Nifi中是否有一种运行python脚本的方法，该脚本具有从不同文件夹导入的模块、在pipfile中指定的需求以及要传递的参数？简而言之，如何使用Nifi执行通常在我的虚拟环境中运行的python脚本？
我的最终目标是使用Get获取一个文件并将其发布到API中。我试过执行进程，执行流命令处理器。
浏览 1提问于2020-04-22得票数 0
1回答
我已经编写了一个自定义NiFi处理器，它使用一些Hadoop类，处理流文件和序列化往返于Avro的流文件。据我所知
要使用Hadoop类而不将它们打包为NAR的一部分，我需要nifi-hadoop-nar包和来将流文件内容序列化到/从Avro，我需要RecordSetWriter和读取器，这是record-serialization-services-api如果我的假设是错误的，请纠正我。
浏览 6提问于2019-09-25得票数 0
我正在使用NiFi和MiNiFi。
这里我已经提到了MiNiFi(windows)目录在ListFile处理器中。创建后，它显示<
浏览 1提问于2019-03-28得票数 1
2回答
我想将Nifi流文件发送到Spark，并在Spark中进行一些转换，然后再次将结果发送回Nifi，以便我能够在Nifi中进一步操作。我不想写流文件写到数据库或HDFS，然后触发火花作业。我想直接发送流文件到星火和接收结果直接从火花到尼菲。我试过在Nifi中使用ExecuteSparkInteractive处理器，但我被卡住了。任何例子都会有帮助。
浏览 1提问于2018-10-31得票数 8
回答已采纳
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告
为NAR中的NiFi扩展生成文
浏览 1提问于2019-08-16得票数 0
1回答
是否可以使用REST将外部数据(而不是NiFi流)存储到NiFi注册表中？
据我所知，NiFi注册表是为NiFi流的版本化而设计的。但我想知道它是否能够将其他数据存储到NiFi注册表中，并根据版本检索它。
浏览 0提问于2018-07-03得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
