我想从Nifi调度我的spark批处理作业。我可以看到有处理器将spark作业提交给Livy，但它执行属性中提供的代码或从传入流文件的内容中执行。我应该如何从Nifi调度我的spark批处理作业，并在批处理作业失败或成功时采取不同的操作？
浏览 1提问于2018-07-18得票数 0
1回答
我想从cassandra数据库中获取一些术语，然后将它们作为参数发送到java程序，该程序将输出一些我需要保存在cassandra数据库中的数据。
如果是的话，nifi是否有可能使用哪种处理器？
浏览 3提问于2017-05-16得票数 2
回答已采纳
根据NiFi文档，此信息被写入流文件属性，而不是流文件内容。因此，我使用了AttributesToJSON处理器。之后，我使用PutFile处理器将这些属性写到一个文件中。生成文件，但其中没有写入属性。每个文件中只写入"{}“。使用LogAttribute processor，我可以看到日志文件中的所有属性，但我希望将它们放在单独的<e
浏览 0提问于2017-12-03得票数 1
我正在尝试在Apache Nifi中创建一个流-情况如下: 1-使用来自kafka的消息(完成) 2-转换为有效的请求正文(完成) 3-保留转换后的消息4-生成oauth2令牌(它是post api) 5-调用post api，将转换后的json作为请求正文并在标头中发送令牌 我尝试了几种方法，比如将转换后的json放入缓存中，并在令牌生成后获取它，但问题是我无法将令牌传递给fetchdistributedcache我尝试将json文件放在我的服务器上，但是getfile不接受任何输入，
浏览 21提问于2021-03-22得票数 0
我希望访问多个数据库，具体取决于输入流文件中发送给ExecuteGroovyStript处理器的“ExecuteGroovyStript”属性。在'ExecuteGroovyStript‘处理器中，我有一个属性'SQL.clientdb’，它指向‘查找’服务。同时，我还委托了一个“DBCPConnectionPool”服务，它包含所有所需的详细信息及其类似于“database.name”值的“name”属性。我试图访问池服务的方式是：def clientDb = SQL.clientd
浏览 0提问于2019-09-11得票数 0
回答已采纳
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。
浏览 100提问于2020-01-22得票数 0
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？
浏览 4提问于2017-05-15得票数 5
回答已采纳
这是关于Nifi中的MergeContent处理器的问题。目前，我需要以一种方式将所有具有一个特定属性的流文件组合在一起。但是发生的情况是，由于有如此多的flowFile具有相同的属性，所以处理器生成几个与该属性合并的不同的流文件，并且这几个流文件应该被合并到一个大的流文件中。它们有没有办法等待所有具有相同属性的流文件进入MergeContent处理器，并同时合并所有这些流文件？
浏览 285提问于2019-05-29得票数 3
1回答
创建包含自定义处理器和一些默认处理器的进程组&将其添加到桶中。用户sys_admin可以添加组到画布和修改它和它的处理器。但这不管用。但是用户test_user可以添加处理器组，然后进入并修改它。所以用户只能从一个桶中添加一些东西，而从不修改它？我基本上希望这个处理器组只被sys_admin用户修改。
浏览 1提问于2019-03-06得票数 0
回答已采纳
通常，当我必须向RestAPI发布多个包含multipart/form-data的文件时，我会使用如下所述的ExecuteGroovyScript：
'GroovyScript' is invalid because ... unresolved dependency: org.apache.httpcomponents#httpmime
我没有此NiFi服务器的管理员访问权限，也无法更改NiFi配置，因此无法修复
浏览 0提问于2021-05-14得票数 1
我已经创建了几个自定义NiFi处理器，但是无法获得要生成的使用文档。“使用”文档指的是右键单击处理器并选择“使用”，这将显示有关该特定处理器的文档。将显示文档面板，但我的自定义处理器都不存在。我在我的自定义处理器类上使用了几个NiFi文档标记，包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告
为NAR中的NiFi扩展生成文档.at org.apache.nifi.NiFi.<init>(Ni
浏览 1提问于2019-08-16得票数 0
我正在尝试编写一个自定义的Nifi处理器，它将接收传入流文件的内容，对其执行一些数学操作，然后将结果写入一个传出流文件中。是否有方法将传入流文件的内容转储到字符串或其他东西中？
浏览 0提问于2018-06-25得票数 0
回答已采纳
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我对Nifi非常陌生，我想知道我是否可以从ExecuteScript中传递Python的输出(stdout、熊猫df、markdown)，而不必将输出写到文件中，以便在电子邮件中发送带有PutEmail
浏览 3提问于2020-03-04得票数 2
回答已采纳
我在Centos 7上使用Apache 0.4.1和Java7，并试图基于一些传入数据创建一个流文件。由于生成了大量数据，我正在运行"OutOfMemoryError: Java堆空间“异常。据我所知，这是因为NiFi在写入流文件时提供的输出流是ByteArrayOutputStream，因此数据存储在内存中。我可以理解为什么会发生这种情况，但是我能够使用GetFile/PutFile来处理一个更大的文件(我尝试加载一个10 it文件，记录它的<em
浏览 1提问于2016-02-23得票数 3
回答已采纳
2回答
根据我读过的所有示例，我认为将NiFi设置为集群会很容易。显然我不能让它工作。我使用的是NiFi 1.5。我只有两台主机，并假装有第三台主机，但NiFi并没有作为集群启动。这些是我对配置文件所做的更改。state-management.xml文件 <id>zk-provider</id>
<class>org.apache.nifi.cont
浏览 0提问于2018-02-24得票数 0
我正在开发一个NiFi处理器，并想用JUnit测试它，但是处理器的一个属性是ControllerService，它是DBCPConnectionPool，但是我不知道如何将这个服务添加到JUnit测试中我尝试新建DBCPConnectionPool()，但没有这样命名的对象，尽管我已经将所有依赖项添加到我的pom文件中，如下所示： <groupId>org.apache.nifi<
浏览 34提问于2019-08-02得票数 1
就像我在自定义属性文件中添加一些属性一样。现在，我想在不向上向下Apache NiFi的情况下读取这些自定义属性。custom.properties中的内容destination=/home/ist/d
我想读取这些属性，而不使用向上-向下的NiFi来执行get、put
浏览 1提问于2017-11-18得票数 0
我是Nifi的新手，正在寻找有关使用Nifi处理器以获得高达100MB/s速度的信息。
浏览 29提问于2020-04-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
