2回答
在nifi中，如果我从单个主题监听Kafka，并且基于路由逻辑，它将调用相应的进程组。然而，在RouteOnContent处理器中，如果给出正则表达式来检查字符串的出现，会不会影响性能，或者在基于条件的路由中如何达到良好的性能。
浏览 2提问于2019-06-17得票数 0
1回答
我正在尝试使用配置文件自定义kylo中可用的标准数据摄取模板。我在kylo/conf目录中的application.properties文件中添加了字段名nifi.getfile.business_line1=Test。当我试图在处理器${ business_line1 }中使用nifi表达式时，它将抛出为“business_line1未找到”。
或者，
浏览 3提问于2017-08-16得票数 3
回答已采纳
我一直试图使用NIFI中的replacetext处理器将我的整数和字符串值转换为JSON格式。但我正面临正则表达式的问题。有人能给我一个搜索值和替换值的正则表达式吗？Sensor_id:2.4,locationIP:2.2,Sensor_value:A}{Sensor_id:2.4,locationIP:2.2,Sensor_value:"A"}
处理
浏览 4提问于2020-01-28得票数 0
回答已采纳
我只是尝试使用Nifi从csv文件中提取头部。我对Nifi很陌生，对处理器也不太习惯。我试图使用GetFile->ExtractText->PutFile获取标题行，并将其输出到另一个目录中。这是我在ExtractText中使用的正则表达式：^(.*)\n
浏览 1提问于2019-03-08得票数 1
回答已采纳
1回答
我已经知道如何编写自定义处理器(扩展org.apache.nifi.processor.AbstractProcessor)。此外，我知道如何设置构建、建立报表和创建我的.nar文件。至少，我想要做
浏览 2提问于2018-07-11得票数 2
回答已采纳
我们正在使用NiFi构建一个数据工作流，并希望最终(自定义)处理器(它运行去重复逻辑)只运行一个NiFi集群节点(而不是在所有这些节点上运行)。我看到NiFi 1.7.0 (尚未发布)有一个PrimaryNodeOnly注释来强制执行单个节点的执行行为。在NiFi 1.6.0中有什么方法或解决办法来强制执行这种行为吗？注意:除了@PrimaryNodeOnly之外，如果NiFi提供了一种只在
浏览 1提问于2018-06-19得票数 4
回答已采纳
我需要将一堆json文件流式传输到Nifi，然后Nifi再转到HDFS。Nifi需要查看json文件中的创建日期(UNIX格式)，然后将其路由到适当的HDFS文件夹。到目前为止，我的处理器设置如下： 消费Kafka -> RouteOnContent (使用正则表达式^"creationDate"：\"0-9{4}-0-9{2}-0-9{2}$) -> PutHDFS然而，"PutH
浏览 15提问于2019-01-29得票数 0
在我的自定义处理器中，我添加了下面的字段 public static final PropertyDescriptor CACHE_VALUE = new PropertyDescriptor.BuilderexpressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES)
.build(); 我希望读取流文件属性(如${fieldName} )和正则表达式</
浏览 31提问于2019-05-14得票数 0
回答已采纳
我在NiFi中使用EvaluateJsonPath处理器来指定一个组合主键，以便将我的JSON数据写入到elasticsearch中。我必须通过连接两个属性来创建一个名为'key‘的属性，比如'attr1’和'attr2‘。在EvaluateJsonPath配置中，我添加了一个属性' key‘，值为'${attr1}${attr2}’(我使用这个键是为了避免elasticsearch<
浏览 0提问于2018-08-13得票数 2
回答已采纳
我是Apache NiFi的新手，我正在尝试解决以下情况：
我有一个文件的格式如下：@RTOajvnodsnvodsvdsonbbvoiroi uvdsoiuvoibvds @RBCinbdiuvidsnb第一行和最后一行是页眉和页脚行。我需要检查页眉行和页脚行分别是否有@RTO和@RBC。如果是，我需要路由流文件。我试图使用RouteOnContent处理器来实现这一点，使用正则表达式(@RTO)[\\S\\s\\w\\W]*(@R
浏览 6提问于2016-10-25得票数 2
我对Nifi很陌生，我正试图在Nifi中运行一个java应用程序，这是一个更好的方法。构建java Jar并使用ExecuteProcess处理器或构建自定义处理器执行java Jar
我尝试过的方法:我的Nifi流中的第一个处理器是ExecuteProcess。我构建的java生成元素集合，打印集合，然后ExecuteProc
浏览 0提问于2020-10-28得票数 0
我在玩NiFi自定义处理器。如何将org.apache.nifi.web.StandardNiFiServiceFacade实例注入自定义处理器实例？背景：
我正在努力实现在处理器执行后停止处理器的目标。我知道nifi处理器只用于流处理，而不是批处理，在批处理中，我们只执行一次作业。但是，为了利用NiFi执行支持，需要这样做。随
浏览 0提问于2018-08-13得票数 0
回答已采纳
使用替换文本处理器将44列文件中的几个列替换为逗号(，)作为分隔符。在替换文本处理器中，我需要用属性更改flow文件中的第3列。所以我把它分成4组，单独用一个属性替换第二组的数据。
如果我这样做，处理器就会挂起。如何用特定属性或字符串替换第n列？
浏览 4提问于2017-11-01得票数 2
回答已采纳
在nifi中，我需要将一堆json文件传输到HDFS。json文件有一个名为"creationDate“的字段，该字段的日期采用UNIX格式。起初，我使用的是"PutHDFS“处理器的"EvaluateJsonPath”处理器。“评估...”处理器的属性为"creationDate“，值为"${creationDa
浏览 14提问于2019-01-30得票数 1
回答已采纳
我试图使用表达式语言在Nifi getMongo查询字段中使用以下查询生成ISO字符串，"remindmeDate": {
"$gte": "${now():format("yyyy-MM-dd'T'HHnow():toNumber():plus(359999):format("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'",'GMT')}&quo
浏览 9提问于2017-06-15得票数 2
回答已采纳
几天前，我陷入了问题(这涉及自定义nifi处理器的错误行为)。调试对我没有帮助。因此，我决定探索nifi模拟框架(我应该已经这样做了，但没有这么做:)，正如关于这个问题的评论中所建议的那样。我正在接受这些链接的帮助：，
我想要做的是将单个流文件发送到自定义处理器。为此，我按照建议使用MergeContent (带有FlowFile v3版本)和PutFile<em
浏览 2提问于2019-05-03得票数 0
回答已采纳
我们可以在我们的自定义处理器中读取nifi.properties中设置的属性吗？例如:如果我们添加一个自定义属性nifi.active.profile = dev/qa或者在启动NIFI传递论据时，我们可以稍后阅读
浏览 4提问于2017-06-17得票数 0
我已经在tailFail中检索了自定义日志数据，然后将数据拆分(逐行)。现在我想从nifi-api.log中获取有用的数据。^(.*)$
但是处理器让流程变得无与伦比。1.我应该如何替换我的表达式？
浏览 64提问于2017-08-25得票数 1
我的最终目标是屏蔽特定文件中的数据。我想要将文件从一个位置移动到另一个位置。在此传输过程中，我必须使用Python脚本屏蔽数据。我在Google Cloud Platform上创建的虚拟机上运行此NiFi，其中我安装了Python-2.7和NiFi-1.9.1。<=\.)[0-9])',value='X')
readFile.to_csv("/path", sep=&#
浏览 1提问于2019-04-25得票数 0
如何在Apache NiFi中清除FetchDistributedMapCache处理器的缓存？我尝试删除持久化目录，也尝试一起给出一个新目录，但它仍然获取旧数据。谢谢你的帮助。
浏览 0提问于2017-04-24得票数 5
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
