我已经将NIFI OPC UA 处理器与Apache Nifi1.3集成在一起。我将按照这个URL 开始。我已经在windows上安装了prosys OPC ua的模拟opc服务器。我能够从NIFI上的GetNodeIDs处理器拉取消息，并使用splitText处理器逐行读取消息并发送到GetValue处理器，如示例中所示，但我的GetValue
浏览 17提问于2017-07-25得票数 0
回答已采纳
2回答
我是OPC UA标准的新手，作为一名java开发人员，我一直在努力为这个标准寻找一个好的java库。
我横跨和Eclipse Milo(或digitalpetri)。我的用例是开发一个NIFI(nifi.apache.org)定制处理器，它可以从Kepware等OPC服务器读取数据，并将这些数据导入我们的bigdata存储，然后在其上构建分析。我想在处理器中实现OPC特性，比如订阅和历史数据访问。
浏览 18提问于2017-03-30得票数 1
理解Apache可以与NiFi集成，如所示。NiFi使用加载Spring应用程序上下文。注意:这种集成不是关于NiFi调用Spring的，如所示。
浏览 0提问于2018-08-29得票数 3
回答已采纳
我按照中描述的步骤从NiFi连接到OPC服务器。opc-ua-stack-1.03.341.0-SNAPSHOT.jarnifi-opcua-service-0.0.1-SNAPSHOT.jar
nifi-opcua-service-api-0.0.1-S
浏览 22提问于2017-07-27得票数 0
1回答
我试图在同步集成平台中导入我的自定义处理器。由于同步集成是基于Apache NiFi的，所以我尝试将编译后的处理器(即.nar文件)放到lib目录中：然后重新启动同步。但我在处理器列表中找不到处理器。我搞错什么了？
浏览 1提问于2017-06-18得票数 1
回答已采纳
我正在集成Apache 1.9.2 (安全集群)和NiFi 3.1.4。HDP包含带有SASL身份验证(Kerberos)的Zookeeper 3.4.6。NiFi节点成功连接到此Zookeeper，同步流和日志心跳。 同时，使用Zookeeper的NiFi处理器无法连接。GenerateTableFetch抛出： org.apache.commons.dbcp.SQLNestedException: Cannot create Po
浏览 93提问于2021-03-17得票数 0
回答已采纳
我有Nifi集群，Kafka也安装在那里。
你能告诉我我在Nifi消费者处理器上做
浏览 2提问于2018-08-14得票数 0
1回答
我有一个Nifi服务器连接到OPC服务器来检索数据并将其发送到Kafka，我的问题是，每次OPC服务器重启Nifi和OPC之间的端口时，我会改变和松开连接，所以我必须确定新的端口，并要求安全团队打开新的端口，有没有办法在Nifi中解决这个问题？或者应该在OPC服务器中修复？
浏览 1提问于2019-10-14得票数 0
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告
为NAR中的NiFi扩展生成文档.该文件应该存在于一个目录中，该目录的名称是处理器的
浏览 1提问于2019-08-16得票数 0
1回答
我使用的是Nifi 0.4.1版本。正在编写自定义代码以将CSV转换为avro格式。我已经创建了类文件，并能够生成nar文件。将nar文件放入lib目录并重新启动nifi服务器。当在nifi工作区拖动处理器时，无法看到为将csv转换为avro而创建的类。谢谢,
浏览 4提问于2016-02-25得票数 3
我有一个NIFI处理器，它订阅OPC UA服务器上的几个标记。我很难找到终止订阅的方法。我的计划是让它继续运行直到我决定停止处理器。我试着为@OnStopped、@OnUnscheduled和@OnDisabled定义函数，但是当我停止或禁用处理器时，它们就不会被调用。我在NIFI1.7上，所以我可以终止处理器的线程，但是我的@OnStopped、@OnUnscheduled和@OnDisabled函数仍然没有被调用。
浏览 1提问于2018-09-17得票数 0
回答已采纳
我正在开发带有hive数据库连接池服务的自定义处理器。在pom文件中添加必要的依赖项，并在自定义处理器文件夹中添加必要的文件夹。我已经创建了类文件，并能够生成nar文件。将nar文件放入lib目录并重新启动nifi服务器。一切看起来都很好。但是，服务没有显示在数据库连接下拉框中。相反，它显示连接id，但每次服务创建时，单击控制器部分中的"create“。对于其他处理器，它似乎工作正常。谢谢
浏览 2提问于2017-02-10得票数 1
回答已采纳
我正在开发一个自定义处理器，它同时使用DBCPService和RecordReader。 <dependencies> <groupId>org.apache.nifi</groupId<groupId>org.apache.nifi
浏览 3提问于2020-09-29得票数 0
回答已采纳
EDTWARNING1a4d1c5d-1317-11fb-23b0-c2732fc64051 ConvertExcelToCSVProcessorid=1a4d1c5d-1317-11fb-23b0-c2732fc64051处理器由于处理故障而管理性地产生11fb-23b0-c2732fc64051 ConvertExcelToCSVProcessorid=1a4d1c5d-1317-11fb-23b0-c2732fc64051处理失败，未指定org.apache.nifi.processor.exception.FlowFileHandl
浏览 32提问于2017-08-21得票数 0
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中，我需要查找某些数据映射的外部CSV记录。注意，这个解码过程很复杂，所以它必须是一个自定义处理器。如何解决这个问题，并在我的自定义处理器中使用org.apache.nifi.lookup.LookupService。
我相信这可能是因为它以nar而不是jar的形式出现。但我的问题是，如何仅在编译时使用LookupService，如何通过解决此问题在运行时使用NiFi</
浏览 4提问于2021-04-05得票数 2
回答已采纳
我想从nifi flow中获取数据，然后做一些事情。之后，我想再次将结果发送到nifi flow。 这是我的nifi流，使用输出端口将数据发送到spark。 ? 为了从Nifi flow中获取数据，我编写了以下函数。)
new SiteToSiteClient .url("http://localhost:8090/nifibuildConfig()
va
浏览 30提问于2020-04-09得票数 1
我是Apache的新手，我开发了一个通过HTTP请求将NiFi数据发送到NiFi端点的应用程序。在Apache NiFi中，我有一个HandleHTTPRequest处理器连接到PutFile处理器，然后连接到HandleHTTPResponse处理器。我也尝试过使用LogAttribute处理器。来自JSON服务的响应代码和HTTP运行正常，但我正在努力确保正确发送NiFi有效负载。在HTTPRe
浏览 9提问于2016-07-06得票数 3
Here 这个处理器在一天多的时间里都读得很好，但后来我得到了这个错误： 2019-06-04 15:09:17,727 ERROR [Timer-Driven Process Thread-7] d.f.fit.processors.opcua.GetOPCDataGetOPCData.java:239) at org.apache<
浏览 9提问于2019-06-04得票数 0
在1.12中引入这个之前，我已经编写了一个自定义处理器来处理多部分帖子。我拥有的处理器和nar工作得很好，但是nar包引入了许多标准处理器的副本，其版本号与我的自定义处理器的版本号相匹配。nar</type>
</dependency> 根据apache nifi wiki上的指南，但完整的nar似乎包含标准nifi处理器的"2.1.1-SNAPSHOT“版本，如Attribute
浏览 11提问于2020-07-10得票数 1
回答已采纳
几天前，我陷入了问题(这涉及自定义nifi处理器的错误行为)。调试对我没有帮助。因此，我决定探索nifi模拟框架(我应该已经这样做了，但没有这么做:)，正如关于这个问题的评论中所建议的那样。我正在接受这些链接的帮助：，
im
浏览 2提问于2019-05-03得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
