我有一个包含JSON的简单FlowFile： { "val" : "0"account.id = "123456789" 我想使用QueryRecord处理器准备JSON保存到数据库中。但我得到一个错误： ? QueryRecord</e
浏览 63提问于2021-01-11得票数 0
回答已采纳
1回答
然后使用每个Id进行另一次搜索。<Id>30275559</Id><Id>30158703</Id></IdList>
</eSearchResult> 我使用EvaluateXPath处理器，添加一个自定义属性"id : //*/Id“。
浏览 46提问于2021-01-07得票数 0
使用Apache，我需要过滤出具有一组特殊字符的NiFi中的记录。
作为一个例子，如果一组特殊字符是"FFF“。
浏览 13提问于2019-10-25得票数 0
回答已采纳
是否可以根据返回单个行结果的SQL查询的结果来路由流文件？例如，如果结果为“1”，则流文件将被处理；否则，它将被忽略。下面的方法对我最有效。使用ExecuteSQL处理器来运行筛选SQL查询。编写该查询的目的是以Shu建议的方式生成单个记录(match)或空记录集(no )。将ExecuteSQL连接到处理器，以便使用路由属性值${executesql.row.count:replaceNull(0):gt(0)}的下列值筛选出不匹配的流文件
注意到，在应用ExecuteSQL在我的例子中，这不是一个问
浏览 1提问于2018-09-25得票数 3
我正在尝试使用Apache nifi中的Putmongo处理器将json数组插入到mongodb中。但是我得到了一个错误： error: current bson type is an array and not a document 下面是我的json： [{"Name":"computer","TotalRevenue以下是我的完整Apache流程： GetFile CSV -> ConvertRecord to Json -> Q
浏览 55提问于2020-12-22得票数 0
我在Apache中工作，我有一个问题:如何在使用QueryRecord处理器的NiFi中处理嵌套数组？试用过：FROM FLOWFILE
但它会抛出错误。如何使用RPATH获得预期的结果
浏览 0提问于2021-04-17得票数 1
我目前正在使用Apache Nifi将数据推送到Elasticsearch中。数据被发送到单个索引，但我希望根据client_id字段的内容将数据动态路由到不同的索引。我有一个QueryRecord处理器在发送到Elasticsearch或丢弃之前做一些过滤。使用JsonTreeReader和JsonRecordWriter设置QueryProcessor
如何在PutElasticSearchRecord中设置索引设置以使用字段client_id的内容作为索引名
浏览 7提问于2021-10-01得票数 0
我正在用API从URL获取一些数字数据，我正在寻找一种方法，在将数据放到文件目录之前，在apache nifi中进行一些数学运算。现在已经谢谢你了。顺便说一下，我正在使用PutFile处理器获取数据并将文件放入某个地方，我使用的是InvokeHTTP处理器。我搜索了一些相关的网站，但我找不到一个可行的方法。
浏览 4提问于2019-07-09得票数 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
我正在尝试在Apache Nifi中创建一个流-情况如下: 1-使用来自kafka的消息(完成) 2-转换为有效的请求正文(完成) 3-保留转换后的消息4-生成oauth2令牌(它是post api
浏览 21提问于2021-03-22得票数 0
我希望导入一个文件，该文件具有以下使用Apache NiFi分配的Avro模式： "type" : "record", { "name" : "PersonType" , "typ
浏览 1提问于2019-03-24得票数 0
回答已采纳
我有日志消息数据，正在被推送到kafka主题，与nifi kafka消费者拉入消息数据，并将其路由到各种drops。根据一组内部用户ID和IP地址，我要清除许多记录。有没有办法在主题前面设置一个阻止列表，在数据到达Nifi之前对其进行过滤，或者有一种方法可以将其添加为处理器，在Nifi上过滤数据，然后沉入各种来源？ 谢谢
浏览 37提问于2021-10-07得票数 0
在Apache NiFi中，我的Mongo正在返回对象数组，如下所示 { fname:john, }, city:Nj ]我的EvaluateJsonPath配置如下所示，但是我得到了"EvaluateJsonPath无法返回标量“错误。*的全名值，尝
浏览 3提问于2019-12-09得票数 1
回答已采纳
1回答
我试图在我的自定义处理器中使用DBCPConnectionPool服务。因此，如何在我们的自定义处理器中使用内置的控制器服务(已经在NiFi上可用)。<groupId>org.apache.nifi</groupId> <version当我尝试使用org/apa
浏览 0提问于2021-11-15得票数 0
但是，今天当我尝试使用run-nifi.bat打开它时，NiFi窗口突然在几秒钟内关闭，并显示以下错误：
2019-04-11 23:07:40,146 WARN [NiFi BootstrapBootstrap Command Listener] org.apache.nifi.bootstrap.RunNiFi Apache NiFi now running and listeninglogging ha
浏览 94提问于2019-04-12得票数 0
使用ExecuteSQL/ExecuteSQLRecord处理器，您可以指定“输出批大小”，这将导致多个流文件。每个流文件都包含executesql.row.count。做AttributesToJSON (drop content) => MergeContent (defragment) => QueryRecord (counting) => EvaluateJSONPath理想情况下，我希望以某种方式在MergeContent上/之后添加属性。问题是，MergeContent正在删除具有相同键但
浏览 1提问于2020-07-12得票数 0
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。并在发布数据之前将该值添加到Http报头中，当获得特定错误代码401时，该值也被更新。 下面是我正在尝试的流程，所有的绿色处理器都是我能做的，但是我只能获取值并添加到invoke http头中。
浏览 100提问于2020-01-22得票数 0
1回答
我是apache NiFi的新手，我使用以下查询将查询记录处理器中的日期类型数据转换为时间戳但是，当我尝试用下面的查询将时间戳转换为日期时，我将面临问题。select {fn CONVERT(CAST(CurrentDate as BIGINT),date)} as CurrentDate from f
浏览 0提问于2018-08-07得票数 3
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号