我使用来自kafka主题(nested json)的数据，这些数据必须根据字段值进行过滤。因此，我使用ExecuteScript processor过滤掉记录并转换一些字段。对于过滤，我在没有使用QueryRecord的情况下使用了findAll函数，它起作用了。这里我的问题是，这种方法是否解决了与QueryRecord处理器相同的过滤目的，因为当传入的流文件中存在嵌套的<
浏览 66提问于2019-05-22得票数 1
回答已采纳
使用Apache，我需要过滤出具有一组特殊字符的NiFi中的记录。name,age,cityFFF,45,London然后，第二个记录必须从csv中取出，并放入另一个csv中请建议我所需要的处理器来实现这一点。此外，如果你能列出需要改变的配置，那将是非常有帮助的。
浏览 13提问于2019-10-25得票数 0
回答已采纳
我想在Nifi中获得excel文件的特定部分。我的Nifi模板像那样；
我应该在第2步和第是否有获得特定行和列的解决方案？注意:如果有一个选择削减ConvertExcelToCSVProcessor，它将对我工作。
浏览 5提问于2021-05-04得票数 1
如何保证NiFi QueryDataBaseTable处理器每次获取增量表时的数据序列。该表有一个名为"SEQNUM“的增量字段。
浏览 0提问于2018-12-18得票数 0
回答已采纳
我一直在尝试nifi，并想知道如何根据属性对json数组进行排序。我有这样的Json
{“名称”：“Backham”，“createdDate”：“2018-05-07:30:09”}，{“名称”：“鲁尼”，“createdDate”：“2016-05-12 19:50还有其他更好的方法吗？谁能告诉我怎么做到这一点吗？
浏览 0提问于2018-05-12得票数 2
回答已采纳
在NiFi数据流中，如果我想根据特定字段的值将单个流文件分割成两组，那么在性能方面，以下列方式使用QueryRecord或PartitionRecord是否更快？QueryRecord:PartitionRecord
在UpdateRecord中，以RecordPath步骤3的输出应该是两个流文件，一个相当于QueryRecord方法的输出。总之，虽然<
浏览 0提问于2018-08-23得票数 1
1回答
然后使用每个Id进行另一次搜索。<Id>30275559</Id><Id>30158703</Id></IdList>
</eSearchResult> 我使用
浏览 46提问于2021-01-07得票数 0
是否可以根据返回单个行结果的SQL查询的结果来路由流文件？例如，如果结果为“1”，则流文件将被处理；否则，它将被忽略。下面的方法对我最有效。使用ExecuteSQL处理器来运行筛选SQL查询。编写该查询的目的是以Shu建议的方式生成单个记录(match)或空记录集(no )。将ExecuteSQL连接到处理器，以便使用路由属性值${executesql.row.count:replaceNull(0):gt(0)}的下列值筛选出不匹配的流文
浏览 1提问于2018-09-25得票数 3
我正在尝试使用Groovy登录一个ExecuteScript组件。每当我调用log.info时，都不会将任何东西写入nifi-app.log，但当我调用log.errorit时，则会这样做。是否有一些log4j配置或其他我需要做的事情？使用Nifi 1.0.xlog.info("FOO-BAZ-INFO") => nothing
log.error("FOO-BAZ-ERROR") =&
浏览 4提问于2016-11-15得票数 4
回答已采纳
我有日志消息数据，正在被推送到kafka主题，与nifi kafka消费者拉入消息数据，并将其路由到各种drops。根据一组内部用户ID和IP地址，我要清除许多记录。我有一个名单，大约20个IP地址和10个用户ID的擦除。有没有办法在主题前面设置一个阻止列表，在数据到达Nifi之前对其进行过滤，或者有一种方法可以将其添加为处理器，在Nifi上过滤数据，然后沉入各种来源？ 谢谢
浏览 37提问于2021-10-07得票数 0
在ProcessorLog处理器中使用ExecuteScript的最佳方法是什么？如果在处理过程中遇到错误，我计划在groovy ExecuteScript中添加一些日志记录。但是，添加日志的尝试没有成功。可能忽略了一些明显的东西。return错误
016-04-07 17:13:51,146 ERROR [Timer-Driven Process Thread-6] o.a.nifi.processors.scri
浏览 0提问于2016-04-08得票数 0
回答已采纳
1回答
在NiFi中，我有一个带有RSID属性的流文件。我需要生成一个基于RSID的UUID v5，并将其作为属性添加到流文件中。此uuid需要基于RSID，因为某些报告将具有相同的RSID，因此需要具有相同的UUID5。 我在Groovy中见过一些方法，它们会生成随机的uuid，但不会生成v5，也不会基于字符串。这可以在Groovy/NiFi中实现吗？如果是这样，将如何做到这一点？我是Groovy的新手。
浏览 58提问于2019-10-18得票数 1
回答已采纳
嗨，我想在nifi中对"ScrollElasticsearchHttp“处理器进行简单的计数。在这个处理器之后使用QueryRecord。我创建了一个新变量，并在Sql下面使用我期望result.count值为10000，这是我的记录计数，但它总是显示
浏览 10提问于2022-04-27得票数 0
可以在queryRecord SQL语句字段中使用子字符串或concat函数吗？看到我有流文件{ "field1": "1, Tom Johnson", "field2":"3", "field3":"xyz" }在QueryRecord处理器SQL查询是，
select substringAfter(/field1, ',') as NAME, substringBefore(/f
浏览 5提问于2022-03-23得票数 1
1回答
示例：{col1，col2，col3，col4} => {col1，加密(Col2)，col3，encrypted(col4)}
如果我的加密过程可以通过使用udf来完成，我如何在NiFi中注册和/或使用在Hive中，可以首先注册udf，例如:使用jar‘hdfs/path/to/jar/abc.jar’将临时函数udf_name创建为'abc.efg.udf_class_name‘；然后执行:从表中选择col1、udf_name(col2
浏览 0提问于2018-11-05得票数 1
回答已采纳
= utm_campaign=Beeline_2021&utm_content=banner_320х480&utm_medium=Media&utm_source=ad&utm_term=mscSELECT '${account.view.id}' AS account_view_id, FROM FLOWFILE org.apache.nifi
浏览 0提问于2021-06-22得票数 2
回答已采纳
我使用的是NiFi ExecuteScript和python。在python脚本中，我添加/修改了处理器的状态stateManager.setState(newmap, Scope.LOCAL)
我是否可以查看/清除NiFi web中的处理器状态？当您右键单击处理器时，像TailFile这样的其他处理器会通过“视图状态”提供此选项，但Exec
浏览 3提问于2016-10-11得票数 1
回答已采纳
1回答
使用NIFI提取流文件中的属性并将其转换为文本格式示例的最佳实践是：我如何使用executeScript处理器使用NIFI wihtout完成这一任务
浏览 1提问于2016-12-07得票数 2
回答已采纳
我计划用executescript处理器编写python代码。由于这是我第一次，我发现很难开始。此外，是否有编写代码的语法文档？
浏览 0提问于2019-06-03得票数 0
回答已采纳
我的python脚本中的代码：if flowFile is not None:2017-07-16 08:17:34,417 ERROR [Timer-Driven Process Thread-9]o.a.nifi.processors.script.ExecuteSc
浏览 7提问于2017-07-16得票数 0
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号