1回答
从自定义处理器获取转换配置: Nifi
etl、apache-nifi
我尝试测试Nifi的功能。我从数据库中提取的数据由名为"id“的特定列组成。我需要使用Nifi将列名转换为"customer_id“。我知道这是一项简单的工作，使用jolt之类的东西。但我的问题是，我需要从其他地方提取这些配置或规则，比如在另一个数据库或其他地方。我不想在jolt转换中硬编码来指定列名，而是从其他位置获取列名。有没有这样做的最佳实践或最佳方法？我必须为此编写任何客户处理器吗?如果是这样，那么编写<e
浏览 24提问于2021-01-08得票数 0
1回答
Snmp陷阱接收器作为Apache Nifi中的自定义处理器
snmp、apache-nifi、receiver、snmp4j、snmp-trap
目标：-寻找在Apache中使用SNMP陷阱接收机制作为自定义处理器的选项。查看参考资料，例如如何在Nifi (和)、GetSNMP的Nifi源代码(包括AbstractSNMPProcessor)、ListenSysLog、GetFile等中创建自定义处理器。现在，当尝试将此代码作为自定义处理器在Nifi中编写时，不确定应该将侦听机制放在何处，然后处理实际的PDU部分。有点像在这里。更多详情:-
GetSNMP处理器</em
浏览 1提问于2019-03-10得票数 1
回答已采纳
1回答
如何为plc创建复杂的nifi处理器？
maven、apache-nifi、plc
我想创建一个自定义的nifi处理器，这样我就可以读取s7 plc数据。为此，我希望将此项目的java代码：转换为nifi处理器。所以，我已经下载了mvn包类型，就像这个网站管理员告诉我的那样：谢谢!
浏览 1提问于2019-04-07得票数 0
1回答
在apache nifi自定义处理器中管理偏移量
apache-nifi
我正在考虑创建一个自定义处理器，用于从没有现有nifi处理器的自定义来源获取数据。我一直在尝试理解Nifi组件如何工作的机制，并看到了一些关于如何创建自定义处理器的优秀文档，然而，我看不到任何关于管理偏移量的内容。假设我有一个运行1秒的处理器，但需要从某个任意的偏移量继续处理，这可能会也可能不会每秒产生结果。我目前的理解是"onTrigger“方法是实现这种逻辑的地方，然而，我不确定Nifi</em
浏览 3提问于2020-03-01得票数 0
1回答
如何在apache nifi中使用putSQL
etl、apache-nifi、data-warehouse
我是一个数据warehousing和apache nifi的初学者.我正在尝试将Mysql表数据放入nifi，然后想把这些数据放到另一个mysql数据库表中，我成功地从数据库表中获取了数据，我还可以使用putFile处理器将该数据打印到文件中。但现在我想将排队的数据存储到mysql数据库表中，我知道有putSQL处理器，但它不适合我。有没有人能告诉我怎么做才对。以下是我的流程的截图PutSQL配置-
我将数据从Av
浏览 101提问于2021-10-06得票数 0
1回答
如何将文件从/user/maria_dev/tutorials/test.csv (HDP)复制到/sandbox/tutorial-files/640/nifi/input (HDF)？
hadoop、hadoop2、hortonworks-data-platform、hortonworks-sandbox、hortonworks-dataflow
在Docker Desktop上使用Hortonworks HDP 3.0.1和HDF Sandbox
我已经登录到HDP，并尝试从/user/maria_dev/tutorials/test.csv复制一个文件到HDF的/sandbox/tutorial-files/640/nifi/input，但不起作用。如何使用HDFS以这种方式将文件从HDP复制到HDF？
浏览 4提问于2021-01-14得票数 0
1回答
应该使用哪些nifi处理器将Xml文件转换为Json并将该文件的特定内容插入mysql数据库？
mysql、apache-nifi、data-conversion、processor
需要什么NiFi处理器才能将xml转换为json &将特定数据从该文件插入到mysql数据库？如何配置所需的处理器？
浏览 9提问于2022-01-28得票数 0
1回答
从Nifi中的配置文件中读取
apache-nifi
我正在尝试读取Nifi中的一个配置文件(conf.txt)。根据该文件中提供的路径，我希望配置nifi处理器中的路径(例如:hdfs文件路径、输入目录路径)。是否可以使用现有处理器，还是应该使用自定义处理器。
有人能帮我一下吗。
浏览 0提问于2017-08-20得票数 1
回答已采纳
3回答
是否可以调试apache自定义处理器？
java、eclipse、apache-nifi
我能够在eclipse中远程调试apache自定义处理器(ref:、、)。中取消下面一行的注释
启动apache nifi使用host=localhost、port=8000在eclipse中创建新的调试配置，并选择自定义处理器的项目。
浏览 0提问于2019-04-23得票数 4
回答已采纳
2回答
Nifi:如何编写自定义处理器
apache-nifi
我想编写nifi处理器，它可以从hdfs目录中读取xml文件，然后将其数据提取到流文件属性中，如果有两个nifi处理器可以获取该文件并读取数据或写入其中的情况，那么如何实现文件锁定，以便一次只有一个处理器可以使用它我还没有写任何自定义处理器。
浏览 5提问于2017-09-30得票数 1
1回答
带有有效负载的Websocket流的Apache NiFi
apache-nifi
如果不是，在让NiFi吞下一条通过WebSocket到达的流时，谷歌FlatBuffers会涉及什么？
(一个简单的TCP流会使它更容易还是更难呢？)我们有一位团队成员希望用NiFi捕获这些数据并将其放到数据库中。就个人而言，由于Flatbuffers支持将二进制转换为JSON，所以我认为编写一个简短的C#、python、java或javascript程序来接收flabuffers、打开DB连接和转储数据几乎更容易(如果需要，可以先转换为JSON )。
浏览 0提问于2018-07-05得票数 0
1回答
支持Spring的Apache Nifi自定义处理器
java、spring、apache-nifi
我正在创建一个自定义的NIFI处理器(目前是NIFI自己的emailProcessor的精简版本)。如何配置？
浏览 5提问于2017-05-01得票数 2
2回答
增加来自NiFi的CQL的请求超时
cassandra、apache-nifi、hortonworks-dataflow
我正在使用NiFi中的QueryCassandra处理器从Cassandra获取数据，但我的查询出现了timedoutexception。当从处理器运行CQL查询时，我想增加请求超时。有没有办法做到这一点，否则我将不得不编写一个自定义处理器？
浏览 20提问于2019-07-19得票数 0
1回答
NiFi -将MDC数据添加到默认记录器
apache-nifi、mdc
我使用的是混合了内置处理器和自定义处理器的NiFi。我需要能够将一些元数据附加到关于生成该日志消息的处理器的日志消息中(包括来自普通/默认/内置处理器)。我能想到的最简单的方法就是为记录器配置MDC。问题是，我不知道在哪里可以将NiFi配置为使用自定义记录器来代替其默认记录器。我确实看到NiFi具有可以实现的ComponentLog接口，因此我将有足够的上下文信息将元数据附加到我
浏览 15提问于2020-06-10得票数 2
回答已采纳
1回答
onTrigger - nifi自定义处理器的工作
apache-nifi
我刚开始学习nifi中的自定义处理器。我想了解onTrigger工作的具体情况。我使用在nifi流处理器接口中定义的属性值在onTrigger函数中执行一些操作。例:自定义处理器中的属性值采用“”分隔的字符串，在onTrigger函数中，我编写了一段代码，将字符串转换为字符串数组，并删除额外的空格。我的问题是，该操作是每次流文件通过自定义处理器时运行，还是只转换一次。
我试过查看开发文档，但找不到这
浏览 0提问于2019-06-11得票数 0
回答已采纳
2回答
如何关闭Nifi处理器调度
apache-nifi
我有GetHttp和InvokeHttp Nifi处理器，它们在Nifi中启动流，但我希望它们只从URL中获取一次，并将数据传递给下一个进程，处理配置我无法关闭调度，如何实现这一点。
浏览 5提问于2017-05-24得票数 3
回答已采纳
1回答
nifi-api:列出所有处理器及其配置
apache-nifi、nifi-api
我想列出我所有的ListenHTTP处理器URL，这样我就可以选择并启动不同的流。但是，我必须解析出配置属性(并且
浏览 19提问于2019-11-21得票数 3
1回答
自定义处理器和背压、节流
apache-nifi
NiFi 1.2.0在处理器中是否需要额外的编码(例如:要实现的某些接口)以使其能够为了背压而“休眠/停止消耗数据”，或者一旦处理器的“
浏览 11提问于2017-07-03得票数 0
回答已采纳
1回答
无法从Azure cloud nifi服务器中的FTP服务器获取数据或队列数据？
azure、ftp、cloud、apache-nifi、ftp-client
我使用的是FTP服务器，它工作在本地，能够从FTP服务器获取数据，但在Azure cloud nifi服务器中，相同的FTP服务器无法从特定的FTP服务器获取任何记录。我使用的是与FetchFTP nifi处理器相关联的ListFTP，并且使用了与ListFTP和FetchFTP nifi处理器的本地配置相同的配置。
有人能建议一下这里发生了什么吗。我附上了我的FTP处理器
浏览 6提问于2018-07-03得票数 0
云服务器
对象存储
ICP备案
云点播
腾讯会议
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号