我正在使用csv处理器的.xlsx文件到ExcelToCsv文件的对话。想要转换一堆.xlsx文件，其中有不同格式的数据到csv。将文件转换为csv后，数据将发生如下更改。https://nifi.apache.org/docs/
浏览 5提问于2020-05-02得票数 0
我是Nifi的新手，正在寻找有关使用Nifi处理器以获得高达100MB/s速度的信息。
浏览 29提问于2020-04-10得票数 0
回答已采纳
在Apache中，我试图读取一个将编码为NiFi的文本文件，然后尝试将其转换为JSON。但是Apache NiFi正在考虑将其作为一条单行。我尝试使用UTF-8处理器转换为ConvertText，但它不支持编码UCS-2 LE BOM。
有人知道如何使用Apache将该文件转换为UTF-8吗？
浏览 15提问于2020-06-15得票数 3
回答已采纳
post将最大轮询记录设置为1，以保证一个流文件中的事件来自同一分区。community.hortonworks.com/articles/223849/simple-backup-and-restore-of-kafka-messages-via-ni.html 这是否意味着如果使用消息分隔符，同一FlowFile中的事件可以来自不同的分区？https://github.com/apache/<em
浏览 11提问于2019-01-19得票数 0
回答已采纳
我有一个包含以下内容的文本文件 2020-10-19 12:12:00.001;alan;male;{"id":"255","val":"22","type":"1","location":"12530,95823","val":"12","type":"1","location":"1214
浏览 58提问于2020-12-02得票数 0
回答已采纳
我正在尝试使用Groovy登录一个ExecuteScript组件。每当我调用log.info时，都不会将任何东西写入nifi-app.log，但当我调用log.errorit时，则会这样做。是否有一些log4j配置或其他我需要做的事情？使用Nifi 1.0.xlog.info("FOO-BAZ-INFO") => nothing
log.error("FOO-BAZ-ERROR") => 2016-
浏览 4提问于2016-11-15得票数 4
回答已采纳
Apache NiFi提供了"ExecuteSQL“处理器来执行查询并以流文件的形式返回结果。但是，如果我们选择执行选项为“所有节点”，NiFi是否会将查询分成不同的批处理，并并行执行每个批处理(类似于SQOOP的方式)？
浏览 45提问于2019-05-14得票数 0
回答已采纳
我的sftp路径中有一些文件，我想使用Ni-Fi重命名相同位置的文件。 请推荐适合我情况的nifi制程。 提前谢谢。
浏览 26提问于2020-01-02得票数 0
我尝试使用一个非常简单的SQL查询来检索Oracle数据库中两个表的连接内容：
2016-05-03 11
浏览 5提问于2016-05-03得票数 2
回答已采纳
1回答
我正在使用consumekafka投票消息，每隔500到10000条记录，而nifi迭代每30秒发生一次。我想消费iteration一旦所有作业完成轮询下一次迭代。但是consumekafka处理器不支持上行连接。 一旦puthdfs成功，我需要使用下一次迭代，在这里我提到了nifi工作流。
浏览 15提问于2020-04-06得票数 0
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告
为NAR中<
浏览 1提问于2019-08-16得票数 0
1回答
服务API不应与实现捆绑在一起。
、、、、
我创建了一个自定义控制器服务(StandardMyService)，它扩展了nifi控制器模块中的DBCPConnectionPool，当我尝试在UI中使用它时，我在日志中得到以下异常：ERROR [我不认为我实现StandardMyService类的方式有什么问题，因为我已经在一个nifi控制器服务maven原型中测试了它，并且它可以工作。我的nifi控制器build.gradle看起来是这样的： impleme
浏览 9提问于2022-06-20得票数 0
回答已采纳
在Apache Nifi中，我从S3中读取了一些日志，这些日志是文本文件中的json对象，我使用SplitText处理器对它们进行了拆分，现在我想根据属性'source=es_ logs‘过滤出一些对象有没有处理这个的处理器？
谢谢你的帮助！
浏览 1提问于2017-01-07得票数 1
我不确定这个问题已经在某个地方解决了，但我在网上找不到有用的答案。
我正试图使用Apache NiFi将Apache NiFi与卡夫卡消费数据集成在一起。我知道Apache是进行这种处理的合适人选，但是如果我们正在处理的NiFi是一个复杂的工作流，那么构建工作流有多容易呢？我们最初考虑使用Java做同样的事情，但后来意识到这可以
浏览 0提问于2019-04-18得票数 3
回答已采纳
1回答
我试图在我的自定义处理器中使用DBCPConnectionPool服务。因此，如何在我们的自定义处理器中使用内置的控制器服务(已经在NiFi上可用)。当我尝试使用org/apache/nifi/record/sink/RecordSinkService打包它时，它开始抛出错误为：在执行org.apache.nifi
浏览 0提问于2021-11-15得票数 0
1回答
我正在尝试将定制的db数据(从Microsoft表中派生，在其他表上连接->是如何到达的)发布到Kafka集群。我能够发布和使用来自Apache NiFi - to /- Apache Kafka的消息。
但我无法在合流云中发布来自Apache NiFi到Kafka的消息。是否可以使用创建的API键发布/消费来自Apache Ni
浏览 8提问于2022-07-27得票数 0
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。下面是我正在尝试的流程，所有的绿色处理器都是我能做的，但是我只能获取值并添加到invoke http头中。我可以让我们实现这一目标的其他过程是什么。 ?
浏览 100提问于2020-01-22得票数 0
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中，我需要查找某些数据映射的外部CSV记录。注意，这个解码过程很复杂，所以它必须是一个自定义处理器。如何解决这个问题，并在我的自定义处理器中使用org.apache.nifi.lookup.LookupService。
我相信这可能是因为它以nar而不是jar的形式出现。但我的问题是，如何仅在编译时使用Loo
浏览 4提问于2021-04-05得票数 2
回答已采纳
我们有一个使用ssl配置的Teiid12.3服务器正在运行。但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
浏览 5提问于2020-04-28得票数 0
我感兴趣的是创建一个在工业PC上运行的软件，连接到某些机床的CNC模型，读取数据，并将其发送到远程云平台。根据需要，数据必须以MTConnect的XML schema格式发送。此外，数据传输必须使用MQTT协议来完成。
为了开发这个系统，我正在考虑使用Apache Nifi。我们的想法是开发自定义nifi处理器，以使用相应的API连接到特定<em
浏览 13提问于2017-12-21得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
