Apache Nifi自定义处理器对另一个处理器的依赖性
Apache Nifi是一个开源的数据流处理工具，它提供了一种可视化的方式来构建、管理和监控数据流。Nifi的核心概念是将数据流看作是一系列的处理器，每个处理器负责执行特定的数据转换或操作。
在Nifi中，自定义处理器是一种用户自定义的处理器，可以根据特定的需求来扩展Nifi的功能。自定义处理器可以通过编写Java代码来实现，然后将其打包成一个可执行的Jar文件，并将其部署到Nifi的运行环境中。
自定义处理器可以依赖于其他处理器，这意味着在执行自定义处理器之前，必须确保所依赖的处理器已经成功执行。这种依赖性可以通过在自定义处理器的配置中指定所依赖的处理器来实现。当Nifi执行数据流时，它会自动解析处理器之间的依赖关系，并按照正确的顺序执行它们。
自定义处理器对另一个处理器的依赖性具有以下优势和应用场景：
- 灵活性：通过自定义处理器的依赖性，可以根据具体的业务需求来定义数据流的执行顺序，从而实现更灵活的数据处理流程。
- 可靠性：通过确保所依赖的处理器已经成功执行，可以提高数据流的可靠性和稳定性。如果所依赖的处理器执行失败，自定义处理器可以选择等待或执行其他操作，以确保数据流的连续性。
- 扩展性：自定义处理器可以根据需要定义多个依赖关系，从而实现更复杂的数据处理逻辑。这使得Nifi可以适应各种不同的业务场景和需求。
推荐的腾讯云相关产品和产品介绍链接地址：
腾讯云提供了一系列与数据处理和云计算相关的产品和服务，以下是一些推荐的产品和链接地址：
- 云原生应用平台 TKE：https://cloud.tencent.com/product/tke
- 云数据库 CDB：https://cloud.tencent.com/product/cdb
- 云服务器 CVM：https://cloud.tencent.com/product/cvm
- 人工智能平台 AI Lab：https://cloud.tencent.com/product/ailab
- 物联网平台 IoT Hub：https://cloud.tencent.com/product/iothub
- 移动开发平台 MDP：https://cloud.tencent.com/product/mdp
- 云存储 COS：https://cloud.tencent.com/product/cos
- 区块链服务 BaaS：https://cloud.tencent.com/product/baas
- 腾讯云元宇宙：https://cloud.tencent.com/solution/virtual-universe
请注意，以上链接仅供参考，具体的产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我想使用getFileSytem()来拉入任何比我们拥有的时间戳更新的文件，但我不能导入它(我的意思是getFileSytem())我有以下代码：
final FileSystem hdfs = getFileSystem();
final boolean recursive = context.getProperty(RECURSE_SUBDIRS).asBoolean();
final Set<FileStatus> statuses;
try {
final Path rootPath = new Path(directory);
statuses = ge
浏览 2提问于2017-11-01得票数 1
我有一个自定义控制器服务，希望与ConnectWebSocket处理器一起使用。控制器服务依赖于nifi-websocket-services-api，不需要自定义接口( my-customer- controller - service -api文件夹为空)。我已经为控制器服务编写了一个测试，它正在通过测试。 但是，我不能选择控制器服务，因为ConnectWebSocket只接受来自nifi-websocket-service-api-nar的控制器服务api。 ? 我希望避免对整个ConnectWebSocket处理器进行重新编码。所以我的问题是： 是否可以配置依赖项，使我的自定
浏览 16提问于2019-04-23得票数 0
回答已采纳
我已经编写了一个用于在BigQuery上执行某些任务的自定义NiFi处理器。我希望能够重用与NiFi捆绑在一起的GCP凭据提供者控制器服务，以用于身份验证。这个是可能的吗？我尝试将nifi-gcp-processors maven依赖项添加到我的项目中，它成功地构建了，但是当我尝试使用我的nar启动NiFi时，它失败了，并显示以下错误消息。
2017-12-14 05:09:27,406 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.util.ServiceConfigurationError: org
浏览 4提问于2017-12-14得票数 0
回答已采纳
我感兴趣的是创建一个在工业PC上运行的软件，连接到某些机床的CNC模型，读取数据，并将其发送到远程云平台。根据需要，数据必须以MTConnect的XML schema格式发送。此外，数据传输必须使用MQTT协议来完成。
为了开发这个系统，我正在考虑使用Apache Nifi。我们的想法是开发自定义nifi处理器，以使用相应的API连接到特定的数控模型，并在下一步中使用另一个nifi处理器来应用MTConnect语义层。最后，将有一个MQTT处理器来远程发送数据。
使用Apache NiFi的原因是，它将允许我们以图形方式配置系统，并将促进其可扩展性。
有没有nifi处理器可以将这个MTConn
浏览 13提问于2017-12-21得票数 2
我正在扩展一个标准处理器来创建一个自定义的nifi处理器。这个项目构建得很好。但是，当我在将新生成的nar添加到lib/目录后重新启动nifi时，nifi无法启动NoclassDefFoundError：
java.lang.NoClassDefFoundError: org/apache/nifi/processor/util/list/AbstractListProcessor
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoad
浏览 19提问于2017-08-15得票数 0
回答已采纳
NiFi 1.2.0
除了由customprocessor.log创建的app.log文件之外，还需要创建一个单独的日志文件，例如，NiFi。
我经历了一些有趣的、现有的线程，然而，我不知道如何使它在代码中工作。
以下是现有的logback.xml：
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="30 seconds">
<contextListener>
<
浏览 5提问于2017-06-07得票数 2
回答已采纳
1回答
我试图在同步集成平台中导入我的自定义处理器。
由于同步集成是基于Apache NiFi的，所以我尝试将编译后的处理器(即.nar文件)放到lib目录中：
/syncfusion_location/SDK/NIFI/lib
然后重新启动同步。但我在处理器列表中找不到处理器。
当我在纯NiFi导入中这样做时，工作正常(这在NiFi文档中也有描述)。
我搞错什么了？
浏览 1提问于2017-06-18得票数 1
回答已采纳
我正在开发一个NiFi控制器服务，该控制器服务具有另一个控制器服务的属性，即dbcpservice。根据github.com/apache/nifi上的源代码，控制器服务的测试也依赖于处理器的测试，即定义一个具有自定义控制器服务属性的TestProcessor，然后通过这个处理器对控制器服务进行操作。但在我的例子中，控制器服务的属性是另一个控制器服务(Dbcpservice)，我不知道如何编写junit测试来设置控制器服务。
浏览 0提问于2020-02-10得票数 0
我在玩NiFi自定义处理器。如何将org.apache.nifi.web.StandardNiFiServiceFacade实例注入自定义处理器实例？
背景：
我正在努力实现在处理器执行后停止处理器的目标。我知道nifi处理器只用于流处理，而不是批处理，在批处理中，我们只执行一次作业。但是，为了利用NiFi执行支持，需要这样做。随着进一步的实验，我将能够使用自定义处理器实例中可用的StandardNiFiServiceFacade实例来实现这一点。
浏览 0提问于2018-08-13得票数 0
回答已采纳
NiFi的生产实例是版本1.8.0。我们有一个自定义处理器，它不断地查看下游连接，以便根据连接的队列大小路由流文件。
以下是我们如何做到这一点的突出片段。。。
String processorId = this.getIdentifier();
ProcessorGroupStatus processGroupStatus = ((EventAccess) getControllerService()).getContollerStatus();
Collection<ConnectionStatus> groupConnections = processGroupStatus.
浏览 4提问于2021-05-14得票数 0
回答已采纳
在1.12中引入这个之前，我已经编写了一个自定义处理器来处理多部分帖子。我拥有的处理器和nar工作得很好，但是nar包引入了许多标准处理器的副本，其版本号与我的自定义处理器的版本号相匹配。 这在我引入SSLContextService控制器之后就开始发生了。添加Controller服务需要添加 <dependency>
<groupId>org.apache.nifi</groupId>
<artifactId>nifi-standard-services-api-nar</artifact
浏览 11提问于2020-07-10得票数 1
回答已采纳
1回答
我已经知道如何编写自定义处理器(扩展org.apache.nifi.processor.AbstractProcessor)。我已经使用了这种技术，我很乐意创建自定义的org.apache.nifi.components.PropertyDescriptor & org.apache.nifi.processor.Relationship字段，以及重写onTrigger方法。此外，我知道如何设置构建、建立报表和创建我的.nar文件。
我还没有搞清楚的是，是否有一个合理的模式来扩展本地NiFi处理器。我希望扩展一个本机处理器，这样我就可以在新的Unit测试中使用我的扩展类(而不是其他类)
浏览 2提问于2018-07-11得票数 2
回答已采纳
如何在不访问apache nifi接口的情况下启动我创建的数据流。是否可以通过运行.bat文件来触发run？我是apache nifi的新手，对apache nifi的局限性一无所知。
我将数据流保存为模板，并希望在不访问apache nifi界面的情况下启动它。
浏览 0提问于2019-10-27得票数 0
我有一个处理器，它依赖于某个jar作为依赖项。但是，对依赖jar的更改非常频繁。因此，我希望能够将jar路径指定为处理器的属性，并让nifi在每次修改属性中的路径并重新启动处理器时加载jar。正如在中所解释的那样，使用应该是可行的。然而，我无法做到这一点。下面是我使用dynamicallyModifiesClasspath属性编写的hello程序代码：
(下面，Djl代表“动态jar加载”，这是一个随机前缀，我猜是用来命名这个hello world程序的。)
DjlDependencyClass.java
这是我的nifi处理器所依赖的类，我希望在我的nifi处理器中动态地更改它的jar路径。
浏览 0提问于2019-05-27得票数 2
回答已采纳
3回答
我能够在eclipse中远程调试apache自定义处理器(ref:、、)。我遵循的步骤如下：
在apache bootstrap.conf中取消下面一行的注释
java.arg.debug=-agentlib:jdwp=transport=dt_socket，server=y，suspend=n，address=8000
启动apache nifi
使用host=localhost、port=8000在eclipse中创建新的调试配置，并选择自定义处理器的项目。
因此，我可以悬停变量，添加观察和步骤等。然而，一旦我得到一些提示，并想改变一些代码，并迅速尝试，可以做什么呢？我
浏览 0提问于2019-04-23得票数 4
回答已采纳
我写了一个基本的自定义处理器，它发送流到“重试”关系，并调用惩罚。
package nlsn.processors.core.main;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import org.apache.nifi.annotation.behavior.ReadsAttribute;
import org.apache.nifi.annotation.behavior.ReadsAttributes;
import or
浏览 2提问于2018-08-17得票数 1
回答已采纳
我在我的nifi集群中看到了一些奇怪的错误，我有一个3节点安全的nifi集群，当我们在所有节点中部署2个节点时，我们有一些定制库nars，启动时没有任何问题，但在一个节点中，我看到了以下错误。
2017-04-20 23:43:34,516 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.lang.NoSuchMethodError: org.apache.nifi.processor.util.StandardValidators.createControllerServiceExistsValidat
浏览 1提问于2017-04-27得票数 1
我不确定这个问题已经在某个地方解决了，但我在网上找不到有用的答案。
我正试图使用Apache NiFi将Apache NiFi与卡夫卡消费数据集成在一起。下面是几个问题，在我的脑海中，然后继续进行这项工作。
Q-1)我们所拥有的用例是:实时读取卡夫卡的数据，解析数据，对数据做一些基本的验证，然后将数据推送到HBase。我知道Apache是进行这种处理的合适人选，但是如果我们正在处理的NiFi是一个复杂的工作流，那么构建工作流有多容易呢？我们最初考虑使用Java做同样的事情，但后来意识到这可以在NiFi中用最少的努力来完成。请注意，我们从Kafka处理的数据中有80%是简单的JSON，而20%是
浏览 0提问于2019-04-18得票数 3
回答已采纳
我有Nifi 1.4.0和Hive 2.3.0。元存储服务运行正常，但由于某种原因，Nifi无法执行PutHiveStreaming处理器。
下面是完整的堆栈。对此有什么想法吗？
at org.apache.nifi.processors.hive.PutHiveStreaming.lambda$onHiveRecordsError$1(PutHiveStreaming.java:527)
at org.apache.nifi.processors.hive.PutHiveStreaming$$Lambda$392/1467727491.apply(Unknow
浏览 1提问于2017-11-09得票数 0
1回答
服务API不应与实现捆绑在一起。
、、、、
我正在开发以下Nifi控制器服务包：
nifi-controllers-bundle nifi-controllersnifi-controllers-apinifi-controllers-narnifi-controllers-api-nar
我创建了一个自定义控制器服务(StandardMyService)，它扩展了nifi控制器模块中的DBCPConnectionPool，当我尝试在UI中使用它时，我在日志中得到以下异常：ERROR [NiFi Web Server-36] o.a.nifi.controller.ExtensionBuilder Could not create Co
浏览 9提问于2022-06-20得票数 0
回答已采纳
NiFi会在抖动处理器中抛出一个错误--尽管“高级”处理器接口中的测试工作得完美无缺！
有些流文件是没有错误地转换的--但是大多数都失败了--例如：
杰森：
{
"abc": {
"HEADER": {
"A": "WDD2132041A2213962",
"B": "75268508"
},
"BODY": {
"C": "OK&#
浏览 0提问于2017-03-24得票数 0
1回答
我已经安装了开放源码hadoop集群并使用了Nifi。当我每天早上检查服务状态时:状态如下。
INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is running at PID 23164
但是没有响应ping请求。
重新启动服务后:状态如下:它将在一天内正常工作。
INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is currently running, listening to Bootstrap on port YYYY, PID=XXXX
ERROR
浏览 15提问于2022-02-17得票数 0
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。
我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告
为NAR中的NiFi扩展生成文档.
根据开发人员的说法，文档应该是自动生成的。
我还试着创建一个additionalDetails.html文件，并根据文档将其放入nar中。
该文件应该存在于一个目录中，该目录的名称是处理器的完全限定名，该目录的父目录应该命名为docs，并存在于处
浏览 1提问于2019-08-16得票数 0
尝试使用命令行启动我在apache nifi中创建的进程组
我已经安装了curl并运行以下命令：
curl -i -X PUT -H 'Content-Type: application/json' -d '{"id":"12ef79d6-016e-1000-c7bd-b71e01f3e1b6","state":"RUNNING"}' http://localhost:8085/nifi-api/flow/process-groups/12ef79d6-016e-1000-c7bd-b71e01f3
浏览 14提问于2019-10-28得票数 0
我试图在我的NiFi安装中安装一个自定义NAR控制器服务包，但是在启动时会得到这个错误。它的行为就像它无法从RecordReaderFactory中找到nifi-record-serialization-service-api类一样，尽管它是作为一个依赖项包含的：
<dependency>
<groupId>org.apache.nifi</groupId>
<artifactId>nifi-record-serialization-service-api</artifactId>
<version>1.
浏览 0提问于2019-03-02得票数 1
1回答
我让Apache NiFi独立运行，运行良好。但是，当我尝试设置Apache NiFi来访问Hive或HDFS时， Kerberized集群。我有问题了。
有人能指导我设置HDFS/Hive/HBase (与Kerberos一起)的文档吗？
下面是我在nifi.properties中给出的配置
# kerberos #
nifi.kerberos.krb5.file=/etc/krb5.conf
nifi.kerberos.service.principal=pseeram@JUNIPER.COM
nifi.kerberos.keytab.location=/uhome/pseeram/lea
浏览 4提问于2016-12-23得票数 3
我正在尝试用mvn archetype:generate在NiFi中实现一个自定义处理器，我想从org.apache.nifi.processors导入一个类(特别是standard.util.*)，但它给了我错误(cannot be resolved)。
我目前的解决办法是复制我想要的包中的类，但是我应该做什么才能使它直接从nifi包中可见？我应该修改pom.xml吗？提前感谢
pom.xml的内容是由mvn archetype:generate命令生成的内容：
<project xmlns="http://maven.apache.org/POM/4.0.0" xml
浏览 4提问于2019-12-20得票数 2
我们有一个使用ssl配置的Teiid12.3服务器正在运行。我们能够使用像pentaho etl、squirrel client、Tableau等工具连接这个teiid服务器，我们正在使用trustore文件连接这些工具。但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
在运行的nifi.bat中添加trustore
- set JAVA\_ARGS=`-Dorg.apache.nifi.bootstrap.config.log.dir=%NIFI_LOG_DIR%` `-Dorg.apache.nifi.bootstrap.config.
浏览 5提问于2020-04-28得票数 0
我正在集成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 PoolableConnectionFactory (Could not open client transport for any of the Server U
浏览 93提问于2021-03-17得票数 0
回答已采纳
我使用像下面这样的流文件给putSQL处理器喂食：
insert into test_nifi values ( '1476781027812');
我也尝试使用没有最终结果的版本；结果是一样的。
2016-10-18 10:49:58,858 ERROR [Timer-Driven Process Thread-4] o.apache.nifi.processors.standard.PutSQL PutSQL[id=d3103678-0157-1000-0000-000036cdfdbc] Failed to update database for [StandardFlo
浏览 1提问于2016-10-18得票数 1
回答已采纳
我已经创建了一个日期工作流，如下所示: GenerateFlowFile --> Custom Processor --> LogAttribute我的自定义处理器有一个属性作为start NiFi。但每次计划的运行中的开始日期应根据上次运行的最大结束日期进行更改。基本上是从服务器获取增量数据。
您能帮助一下，如何在Apache NiFi中实现这一点？
浏览 1提问于2017-04-14得票数 1
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中，我需要查找某些数据映射的外部CSV记录。注意，这个解码过程很复杂，所以它必须是一个自定义处理器。我知道可以设置外部CSVRecordLookupService，然后在CustomController中定义一个属性描述符，如下所示
public static final PropertyDescriptor CLIENT_LOOKUP_SERVICE =
new PropertyDescriptor.Builder()
.name("Client CSV L
浏览 4提问于2021-04-05得票数 2
回答已采纳
我在Nifi中导入了一个新的OPCUA包。Here 这个处理器在一天多的时间里都读得很好，但后来我得到了这个错误： 2019-06-04 15:09:17,727 ERROR [Timer-Driven Process Thread-7] d.f.fit.processors.opcua.GetOPCData GetOPCData[id=1e5f35cf-3df7-1e7d-1521-5c8fe9fbd8f6] Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java
浏览 9提问于2019-06-04得票数 0
* Update：我已经改变了我在回答问题时所描述的方法，由于这个问题，原来报告的问题变得毫无意义。***
我正在尝试开发一个Nifi应用程序，它为Kakfa提供了一个WebSocket接口。我无法使用标准的Nifi组件来完成这一任务，因为我已经尝试了如下(这可能没有意义，但直觉上这正是我想要实现的)：
我现在已经创建了一个自定义处理器"ReadFromKafka“，我打算使用它，如下图所示。"ReadFromKafka“将使用与标准"PutWebSocket”组件相同的实现，但会读取来自卡夫卡主题的消息并作为对WebSocket客户端的响应发送。
浏览 6提问于2021-09-06得票数 0
在Apache中，每个处理器之间都有连接，它们的作用类似于FlowFiles队列，而在默认情况下，Nifi将FlowFile的数据内容保存在磁盘上。这是否意味着每个这样的连接都在磁盘上持久化FlowFiles？如果是这样的话，每次将FlowFiles从一个处理器传递到另一个处理器将意味着一个磁盘的读写，因此更多的处理器将导致更多的磁盘读和写，这反过来将降低整个吞吐量。我的理解正确吗？在一个处理器中编写所有东西，避免这种情况的最佳实践是什么？谢谢。
浏览 4提问于2022-05-09得票数 0
我有一个扩展MergeContent进程的自定义处理器，当NiFi启动时，我在日志中看到以下错误：
2016-09-09 18:17:00,607 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.util.ServiceConfigurationError: org.apache.nifi.processor.Processor: Provider org.apache.nifi.processors.standard.DetectDuplicate could not be instantiated
j
浏览 8提问于2016-09-10得票数 2
回答已采纳
理解Apache可以与NiFi集成，如所示。NiFi使用加载Spring应用程序上下文。
问: NiFi能否与Spring集成？具体来说，NiFi处理器是否可以流向调用Spring应用程序的处理器，然后再流回NiFi处理器？如果是这样的话，是否有任何样本来证明它？
注意:这种集成不是关于NiFi调用Spring的，如所示。
浏览 0提问于2018-08-29得票数 3
回答已采纳
1回答
我试图在读取流文件的同时输出流文件。(它在读取完文件的一部分而不是整个文件后立即输出) 但是，ProcessSession似乎要求在目标处理器可以读取所有流文件之前提交它。否则，可以选择将其迁移到另一个处理器。 如何使用迁移功能？更具体地说，我从哪里获得“newOwner”值？ 或者有没有人对我原来的问题有什么想法？ 下面是ProcessSession代码：github.com/apache/nifi/blob/master/nifi-api/src/main/java/org/apache/nifi/processor/ProcessSession.java 我非常感谢任何使用迁移的示例处
浏览 12提问于2020-01-03得票数 1
我使用Cron驱动的调度策略运行多个GetSplunk处理器。Cron表达式看起来是‘03013** ?’。在第一次运行查询时，它们都成功地执行了查询。但是，第二天，它的错误与401来自Splunk的错误。来自nifi-app.log的错误如下所示。NiFi中的Cron调度程序是一个QuartzScheduler。
WARN [Timer-Driven Process Thread-7] o.a.n.c.t.ContinuallyRunProcessorTask Administratively
Yielding GetSplunk[id=01581009-026c-114b-5e2e-40
浏览 3提问于2017-01-13得票数 4
回答已采纳
我已经创建了一个使用jackson json库的自定义处理器，单元测试运行良好。
我对构建哪个项目/模块来创建目标nar有点困惑。
处理器(Maven)项目的pom.xml是：
<?xml version="1.0" encoding="UTF-8"?>
<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor
license agreements. See the NOTICE file distributed with this
浏览 17提问于2017-03-07得票数 1
回答已采纳
我正在做一个与Apache NIFI的集成工作，我们偶然发现需要做双向TCP。在此之前，我们只使用单向TCP。
Apache NIFI通过'ListenTCP‘和'PutTCP’等功能支持单向TCP。HTTP和websocket域通过'HandleHttpRequest‘、'HandleHttpResponse’、'ConnectWebSocket‘、'ListenWebSocket’和'PutWebSocket‘等功能支持双向TCP。纯粹的双向TCP机制看起来并不明显。
通常，我会使用Python、Servicemix或..不管怎样..
浏览 33提问于2017-07-21得票数 2
我遇到了一个NiFi写HDFS的问题。我收到一个错误：
ERROR [Timer-Driven Process Thread-10] o.apache.nifi.processors.hadoop.PutHDFS PutHDFS[id=4af43efa-a8ff-18ac-0000-00002377fba5] Failed to properly initialize Processor. If still scheduled to run, NiFi will attempt to initialize and run the Processor again after the &
浏览 0提问于2020-03-01得票数 1
我正在评估Apache Nifi将数据从Postgresql数据库移动到Hive。在将数据移动到Hive时，我需要使用查找表来屏蔽/转换某些数据属性，这与使用ETL工具中提供的查找转换可以完成的操作类似。在Apache Nifi中有哪些选项可以实现同样的功能？
浏览 1提问于2016-11-02得票数 1
Apache Nifi上的另一个问题是，如何获取处理器的组id，当您右键单击处理器，然后单击stats时，该id也会出现？有没有办法将这个组id值存储为某些属性/流文件内容的一部分。
我需要组id，这样我就可以使用来自rest api的公告消息来获取公告错误。
https://{host}:{port}/nifi-api/controller/process-groups/{process-group-id}/status?recursive=true
浏览 6提问于2016-05-26得票数 0
在Apache中，我试图读取一个将编码为NiFi的文本文件，然后尝试将其转换为JSON。但是Apache NiFi正在考虑将其作为一条单行。
我尝试使用UTF-8处理器转换为ConvertText，但它不支持编码UCS-2 LE BOM。
有人知道如何使用Apache将该文件转换为UTF-8吗？
浏览 15提问于2020-06-15得票数 3
回答已采纳
我陷入了一个问题，NIFI服务就是拒绝启动。我监控了nifi-app.log，发现是OutOfMemory错误。我在bootstap.conf文件中增加了内存。但是这个错误仍然存在。
附件是nifi-app.log
2017-12-19 17:08:37,133 ERROR [ActiveMQ InactivityMonitor ReadCheckTimer] org.apache.nifi.NiFi An Unknown Error Occurred in Thread Thread[ActiveMQ InactivityMonitor ReadCheckTimer,5,main]:
浏览 57提问于2017-12-20得票数 6
回答已采纳
1回答
我已经开始使用Apache Nifi了，我还在学习和试验它。我真的很想使用Nifi从API中获取JSON文档，并将它们放入我的Elasticsearch数据库中。到目前为止，使用内置的getTwitter和putElasticsearch控制器，这是可行的。
然而，现在我想用Twitter以外的其他API来做这件事，我有点被困在这里了。首先，我真的不知道该使用哪个控制器？我会认为是getHttp或invokeHttp，即使把'GET‘作为http动词then，但它似乎不起作用。如果我使用getHttp，我必须提供一个带有密钥库和信任库的SSL服务。比如我为什么要这么做？
Apache
浏览 0提问于2016-03-03得票数 0
我制作了流程，处理来自本地服务器的实时数据，并将相关数据发送到Elasticsearch。我使用了Minifi，但当我运行MiNifi时，它返回了以下错误。有人知道问题出在哪里吗？
谢谢
由于java.lang.NoClassDefFoundError，PutElasticsearch5id=4ed70cbe-9838-35cd-0000-000000000000 PutElasticsearch5id=4ed70cbe-9838-35cd-0000-000000000000无法处理计时器驱动的进程线程-10 o.a.n.p.elasticsearch.PutElasticsearch5 ja
浏览 18提问于2018-02-05得票数 0
如何在NiFi ValidateRecord processor / JsonRecordSetWriter中将时间戳序列化为Json字段。
在输入时，我有一个CSV文件，其中包含一个格式为yyyy-MM-dd HH:mm:ss.SSS的时间戳列。在我的NiFi流中，我有一个ValidateRecord处理器，它使用CSVReader进行读取，使用JsonRecordSetWriter作为编写器。它们都使用Avro模式，时间戳字段定义如下
"fields" : [ {
"name" : "timestamp",
"type
浏览 143提问于2018-10-19得票数 1
回答已采纳
我使用的是Kafka版本2.0.0。我已经在Kafka中启用了SASL_PLAINTEXT，并从控制台生产者和控制台消费者那里进行了测试，它对我来说很有效。现在，我正在尝试使用消费Kafka和发布Kafka处理器来发布和使用来自Nifi的数据，但我无法进行连接。我的错误越来越小。
Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: unable to find LoginModule class: org.apache.kafka.common.security
浏览 173提问于2020-02-24得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
