3回答
我有一个合并了所有记录的json，我需要拆分合并后的json并使用NiFi加载到单独的数据库中db.collection.findOne()[ ""company": "ddr" { "id": 104,
"company": "sir&qu
浏览 5提问于2016-10-27得票数 1
我需要将前一天处理和合并的json文件移动到新的hdfs路径中。要求是递归地搜索未处理的文件并移动挂起的未处理的文件。Path 1 -> /data/nifi/working/2019/10/source_2019_10_15.json -每日处理的文件将合并到此路径下，并按天添加。路径2 -> /data/nifi/incoming/ --如果文件夹不存在，代码应该搜索，如果
浏览 1提问于2019-10-17得票数 0
我设置了以下流程，用于读取json数据并使用convertRecord处理器将其转换为csv。但是，输出流文件是，只填充单个记录(我假设只有第一个记录)，而不是所有记录。来源json数据：{"creation_Date": "2018
浏览 1提问于2018-08-21得票数 0
回答已采纳
我有一个场景，我将不得不在Nifi Kafka消费者处理器中合并消息，通过Kafka生产者Jar发送的消息在本地调用..i能够在kafka消费者控制台中消费消息，但不能在Nifi...how中查看消息，如果消息为json格式
浏览 23提问于2020-02-17得票数 0
我有一个文本文件，当我使用合并内容处理器数据附加无法合并时，我需要使用NIFI将文本文件合并为一个文件 示例:-如果我的文本文件有这样的数据 在file1:- 2201和file2:- 2202中使用nifi中的合并内容后，我得到的输出是22012202 合并内容处理器:- ? 但我需要输出如下2201 2202 2203可以有人帮助我，我只需要在nif
浏览 18提问于2019-09-05得票数 1
回答已采纳
我正在构建nifi中的流，在流中我需要通过一个字段过滤JSON。因此，我决定拆分json，然后通过SplitJson和MergeContent处理器合并过滤部分。*/i)]，所以它拆分正确，但是当我想将所有部分合并到一个json文件中时，(Merge Strategy = Defragment)和它合并文件的方式是错误的。MergeContent处理器是这样的：
[ {"name":"Test"}, {"nam
浏览 1提问于2019-07-28得票数 1
回答已采纳
1回答
我正在使用JSON1.11.4构建一个数据管道，其中IoT设备以NiFi格式发送数据。每次从IoT设备接收数据时，我都会收到两个JSON；{ devValue: "TWOINITIALCHARS23",和JSON_FINAL在我的用例中，我需要以这样的方式合并这个JSON，我得到的JSON如下所示(请注意在两种情况下都删除了TWOINITI
浏览 6提问于2020-08-05得票数 0
我仍在学习使用java编写Apache的编程，我想知道是否有人能向我解释如何使用NiFi REST & java实例化NiFi平台？任何使用Apache和NiFi创建处理器的解决方案。client = HttpClients.createDefault();
HttpPost httpPost = new HttpPost("http://localhost:8080/nifi-api
浏览 2提问于2020-03-03得票数 1
运行此命令日志13:50:51.513 [main] INFO org.apache.nifi.StatelessNiFi - Finished unpacking 100/test&#
浏览 2提问于2019-12-18得票数 1
我有一个Nifi流，在Json中有多行数据，对于每个行，需要执行以下操作：
拆分数据(EvaluateJsonPath)并将相关字段插入数据库(Mysql)，将表A的字段取为表A，并将它们放入DB中。从表插入获取返回值，并与表B字段合并。表A的返回值成为表B中的引用值，因此分隔行条目成为链接。我已经设置了flow (见图)，但是MergeContent处理器失败了，因为我认为它不知道如何正确地合并内容。如果我有200行，它只合并一行，其余的就失败了。我在Nifi中读过关于碎片整理的文章，
浏览 7提问于2019-11-15得票数 1
我使用NiFi接收一些用户数据，并将所有JSON合并到一个记录中。MergeRecord处理器就像我所需要的那样工作，除了总是遗漏一条记录(通常每次都是相同的)。处理器被设置为运行60秒。我不明白为什么，因为只有56个记录要合并。我在下面给你们提供了任何帮助。
浏览 6提问于2021-12-08得票数 0
Nifi内容存储库在重新启动后的一段时间内与Nifi状态栏同步工作，Nifi版本1.9.1。在那之后，它开始逐渐增长，只有在重新启动时才会再次下降。我混合了小文件和大文件，并且正在合并文件以在流中创建大文件。我可能遇到了一个错误，https://issues.apache.org/jira/browse/NIFI-6150可能在下面提到的三种情况下都不起作用： 1)既有小文件又有大文件。2)合并小文件创建大文件。我有几个大文件，只有在重新
浏览 23提问于2020-05-02得票数 3
我正在尝试使用NiFi MergeContent将多个拼图文件合并在一起。对我通过ConvertRecord操作符获得的拼图文件执行https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.
浏览 36提问于2021-01-05得票数 0
回答已采纳
这是关于Nifi中的MergeContent处理器的问题。目前，我需要以一种方式将所有具有一个特定属性的流文件组合在一起。但是发生的情况是，由于有如此多的flowFile具有相同的属性，所以处理器生成几个与该属性合并的不同的流文件，并且这几个流文件应该被合并到一个大的流文件中。它们有没有办法等待所有具有相同属性的流文件进入MergeContent处理器，并同时合并所有这些流文件？ 如果不是，还有什么办法呢？
浏览 285提问于2019-05-29得票数 3
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我们正在通过Kafka主题从上游系统接收Json消息。需求是以一定的间隔将这些消息存储到HDFS中。因为我们要存储到HDFS中，所以我们希望将这些记录中的某些数量合并到单个文件中。根据NiFi ，我们为此使用了处理器。
下面是处理器配置的快照。<
浏览 1提问于2019-03-28得票数 2
我正在使用NiFi，在同一个文件中接收几个json。假装正确地修改了这些jsons，我将其分成几个单独的流文件，问题就从这里开始。对于每个id和datetime，有3个流文件我想要合并到一个流文件中。我试过使用MergeRecord的NiFi处理器，但它可以在需要时工作。当我有几张唱片的时候，似乎一切正常。有时它将2条记录合并在一个记录中，有时允许直接传递一条记录。merge_key是一个基于id和datetime的字符串属性。
我需要准确的3条记录，并将它们合并在一个单一的
浏览 0提问于2020-06-29得票数 0
我在Nifi中使用MergeContent处理器将两个far文件合并到一个大JSON对象中，我到目前为止所做的工作如下：
浏览 3提问于2016-12-07得票数 1
回答已采纳
我正在尝试使用NiFi的PutCassandraRecord处理器将一些JSON记录插入到Cassandra DB中。schema: org.apache.nifi.serialization.MalformedRecordException: Successfully parsed a JSON object fromschema
at org.apache.nifi.json.AbstractJsonRowRecordReader.nextRecord(Abstrac
浏览 8提问于2019-05-14得票数 1
我使用来自kafka主题(nested json)的数据，这些数据必须根据字段值进行过滤。因此，我使用ExecuteScript processor过滤掉记录并转换一些字段。这里我的问题是，这种方法是否解决了与QueryRecord处理器相同的过滤目的，因为当传入的流文件中存在嵌套的json对象时，我不确定如何使用查询记录。
浏览 66提问于2019-05-22得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
