我是Nifi的新手。我已经在Nifi中定义了一个处理器组，并且已经启动了数据流。 在后端，如何检查处理器组的状态是否正在运行？我试过了 /bin/nifi.sh status 但是它只给出了nifi的总体状态，不管它是否正在运行。
浏览 21提问于2021-04-09得票数 0
回答已采纳
我使用的是NiFi 1.9.1，我是这个集群的系统管理员。 在nifi-app.log中，我从所有处理器组获取日志。有没有办法将日志线分开，以便根据处理器组，一组用户只能看到他们感兴趣的那些处理器的日志。 谢谢
浏览 28提问于2019-04-10得票数 0
回答已采纳
我正在探索NiFi提供的rest功能。我有一个问题:通过查询组件的名称，我们是否可以使用NiFi-API获取组件的ID，无论是处理器、处理器组、控制器服务等等？我尝试了http://localhost:8080/nifi-api/flow/search-results?q=sample，在我的NiFi流中有一个名为sample的处理器组。
我有一个名为GetF
浏览 0提问于2017-04-05得票数 3
回答已采纳
1回答
我对Nifi非常陌生，我尝试对SQL server执行SQL，其中包含多个表，并从每个表中选择属性。我们怎么才能在Nifi上表演呢。我看到“生成表获取”，它允许我提到“表名”和它的“哪里条款”。
浏览 0提问于2018-11-07得票数 2
回答已采纳
使用此NiFi应用编程接口端点GET "/process-groups/{id}/processors"，能够获取根进程组的所有处理器部分。每个处理器都有一个名为"type"的属性。因此，要获取所有唯一的处理器类型(例如: ConsumeKafka)，我可以遍历所有处理器并查找其"type"属性。 是否有任何现有的NiFi REST端点来
浏览 34提问于2020-07-28得票数 0
回答已采纳
Apache Nifi上的另一个问题是，如何获取处理器的组id，当您右键单击处理器，然后单击stats时，该id也会出现？有没有办法将这个组id值存储为某些属性/流文件内容的一部分。我需要组id，这样我就可以使用来自rest api的公告消息来获取公告错误。https://{host}:{port}/nifi-api/controller/process-groups
浏览 6提问于2016-05-26得票数 0
我有一个nifi流，它保持了ListS3处理器的一些状态。我有一个dev实例和一个prod实例。我想要一些从dev部署到prod的选项，其中保存了状态，并且我不必手动进入并更改所有处理器和进程组。基于以下堆栈溢出问题： how does NIFI listfile maintains its timestamp? 编辑:为了避免误解，我希望在部署时保持prod状态。
浏览 14提问于2021-03-19得票数 0
回答已采纳
使用Hbase处理Nifi。在这篇文章中，我从Hbase获取数据，使用Gethbase处理器并将数据发送到Nifi.But中的Putfile处理器。我在Nifi .Any建议中收到错误消息“由于java net连接异常，无法从Hbase接收数据:连接被拒绝”请
浏览 1提问于2016-05-04得票数 0
我正在使用Java语言创建NiFi自定义处理器，其中一个要求是使用Java代码获取以前的处理器名称和处理器组(就像一个面包屑)。
浏览 0提问于2020-08-20得票数 1
例如，我在nifi集群中有3个nifi节点。nifi-rest。我有用于从rest获取集群摘要的GetHTTP处理器，并且这个处理器只运行在pimary节点上。我确实将这个处理器的"URL“属性设置为192.168.12.50:8080/nifi-api/controller/cluster.
但是，如果主节点关闭，则将选择新的主节点。因此，我将无法从新的主节点访问192.168.12.50:8
浏览 0提问于2019-01-25得票数 2
回答已采纳
我想在某些NiFi处理器中记录故障原因。但我发现它可能有多种原因。SplitAvroJson处理器的示例：“如果FlowFile由于任何原因(例如，FlowFile无效)处理失败，它将被路由到此关系”
是否有可能获得失败的确切原因，以便将其保存在put文件中？
浏览 4提问于2016-04-26得票数 7
1回答
有没有办法只停止NiFi进程组的第一个处理器？
我知道通过Nifi可以停止整个处理器组，但我想要的是只停止该组的第一个处理器，因为我知道该组的id。
浏览 2提问于2019-07-02得票数 0
回答已采纳
我有一组进程组在1.8.0 NiFi服务器上愉快地运行。我在一个单独但类似的服务器上构建了一个NiFi 1.11.1实例，并在相同的进程组上进行模板化。在新的1.11服务器上，处理器(它们都没有明显的类型差异)处理一小批任务，然后挂在一个任务上几个小时。重新启动处理器没有明显的效果，重新启动NiFi实例本身通常会让处理器在问题重新出现之前很好地运行一到两分钟。日志中没有错误，内存的增加没有影响，处理器的使用不会超过2
浏览 3提问于2020-04-24得票数 2
回答已采纳
我是新的Nifi.My要求是触发Nifi进程组使用外部调度工具称为控制M。我尝试使用外壳脚本启动and.stop进程组使用curl命令。进程组将从文本文件中获取数据并写入数据库，但无法确定进程组何时完成，因为我可以看到state、Running和Stopped等状态，但未完成。遇到这个问题，我需要您的宝贵意见，如何确定所有记录被插入到数据库中的进程组内
浏览 29提问于2021-09-04得票数 0
我正在使用Nifi中的listfile处理器。List+Fetchfile将在指定的目录中查找文件。但是，放置在目录中的文件具有不同的用户名和组。为了让Nifi读取我的文件。我得给波音777许可然后，只有Nifi列出并获取文件以进行further.Is，可以在Nifi中指定用户名以使用下面的特定username.For示例。我想以user_abc而不是Nifi的形式列出文件-rw-r--r-- 1 user_abc group1 12549
浏览 0提问于2018-03-28得票数 0
我希望使用NiFi rest将流文件传输到输入端口。我正在浏览NiFi rest文档，发现似乎有实现相同目标的支持。然而，诚实并不是很清楚，也不是很详细。我的工作流程如下：源处理器组中的：
目标处理器组中的：
我想知道的是如何将排队的流文件从源处理器组传输到目标处理器组的输入端口，以便使用PutFile存储。我想尝试到达这个端点：http://localhost:80
浏览 2提问于2017-04-05得票数 0
更新:当启动处理器组，并离开Nifi时，我希望接受失败提醒，以便返回Nifi更新处理器组。
当任何一个处理器报告错误时，我如何接受故障警报？TIA
浏览 1提问于2019-10-18得票数 0
我正在考虑创建一个自定义处理器，用于从没有现有nifi处理器的自定义来源获取数据。我一直在尝试理解Nifi组件如何工作的机制，并看到了一些关于如何创建自定义处理器的优秀文档，然而，我看不到任何关于管理偏移量的内容。假设我有一个运行1秒的处理器，但需要从某个任意的偏移量继续处理，这可能会也可能不会每秒产生结果。我目前的理解是"onTrigger“方法是实现这种逻辑的地方，然而，我不确定Nifi中是否有任何机制可以用来标记以前执行的偏移量，这样我
浏览 3提问于2020-03-01得票数 0
我们有多个团队nifi应用程序在同一台nifi机器上运行...有没有办法记录特定于我的应用程序的日志？另外，在默认情况下，nifi-app.log文件很难跟踪问题，公告牌仅在5分钟内显示错误消息...如何在Nifi中捕获错误并发送邮件警报？
请帮我解决这个问题。提前感谢！
浏览 10提问于2019-03-30得票数 3
我无法启动或停止两个处理器: PutHiveQL和ListHDFS，因为内存过载，我不得不重新启动NiFi。其他处理器反应良好。即使在4小时后，处理器也不会做出反应。我尝试通过停止进程组来停止处理器，但失败了。
浏览 2提问于2018-06-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
