MiNiFi -如何获取处理器列表和排队流文件的数量？
MiNiFi 是一个轻量级的数据收集和流转工具，用于将数据从分布式系统和边缘设备收集到集中的数据流平台。要获取 MiNiFi 中的处理器列表和排队流文件的数量，可以采取以下步骤：
- 登录到 MiNiFi 的管理界面：通过浏览器访问 MiNiFi 的管理界面，通常使用 http://localhost:10080/ 或者指定的 IP 地址和端口进行访问。
- 导航到 Processors 页面：在管理界面中，导航到 "Processors" 页面，该页面列出了当前 MiNiFi 实例中配置的所有处理器。
- 查看处理器列表：在 "Processors" 页面中，你将看到一个处理器列表，其中包含了所有配置的处理器及其相关信息。你可以查看每个处理器的名称、类型、状态以及其他属性。
- 获取排队流文件的数量：对于每个处理器，你可以点击它的名称，进入处理器的详细信息页面。在该页面，你可以查看该处理器当前排队的流文件数量。这个数字表示当前等待被处理的流文件数目。
需要注意的是，MiNiFi 的具体版本和配置可能会对以上步骤产生影响，因此在实际操作中请参考相关的 MiNiFi 文档或者腾讯云的 MiNiFi 相关产品文档进行操作。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云 MiNiFi 产品介绍：https://cloud.tencent.com/product/minifi
相关·内容
我想监控正在运行的MiNiFi流的状态，特别是获取处理器的列表和每个处理器的排队流文件的数量。我正在尝试使用FlowStatus Script Query，例如： $ ./minifi.sh flowStatus systemdiagnostics:processorstats
{&
浏览 19提问于2019-05-23得票数 0
我的Tailfile处理器一直在处理我正在跟踪的整个文件。这会造成这样一种情况:我有一个20mb的文件被添加到我的流中，然后大约一分钟后，我将有一个21mb的文件，等等。为什么它会这样做？以下是配置我让这个处理器通过minifi为我的nifi流提供数据。因此它在机器上是本地的，然后通过远程进程将其发送到我的<
浏览 0提问于2017-10-11得票数 2
连接Minifi++实例到C2 (命令和控制)服务器有问题。我还验证了C2服务器可以提供一个配置好的模板(至少在从具有正确凭据的浏览器完成请求时如此)。现在我已经放弃了所有的连接/网络和身份验证
浏览 2提问于2020-07-27得票数 0
我有一个自定义处理器(NiFi 1.8.0)，它已经根据需要修改了传入的流文件。但是，在将文件传输到传出关系之前，我想检查一下该关系的背压是否接近超过它的阈值。如果是，那么我计划将流文件发送到另一个连接到PutFile处理器的关系，在那里它将被写入磁盘。 我知道我可以得到传入队列的数量和大小。但是我不知道如何从外向关系的
浏览 29提问于2019-12-04得票数 0
回答已采纳
我有一个下面的场景，我正在尝试
get新文件列表与ListFile处理器一起设置一个常量变量zipFilesBundleConstant = listBundle对每个流程文件，将该列表放到数据库中，得到数据库中所有新旧文件列表，以便与ExecuteSQL处理器进行进一步处理。(在这里，我只想调用一个数据库调用来获取完整的列表(旧的和新的)，但是
浏览 1提问于2020-06-01得票数 1
只需将文件从一个HDFS dir自动移动到另一个HDFS dir即可。在Apache中使用moveHDFS处理器执行此操作，但是启动处理器时似乎不会发生任何事情。经过长时间的处理后，处理器度量保持在零。它不应该使用提供的hadoop配置文件来访问hadoop集群上现有的HDFS吗？)将NiFi作为单个实例安装在hadoop集群节点上，并根据需要将核心文件和hdfs-site.xml文件添加到处理器属
浏览 1提问于2018-05-04得票数 1
回答已采纳
2回答
我正在尝试测量用于执行工作流的处理器时间和总内存的数量。我有一个调用WCF服务的ASP.NET应用程序。WCF服务执行几个方法，然后使用WorkflowApplication类的Run方法调用与其关联的工作流。我一直在使用“Process”类别中的性能计数器来获取关于处理器时间百分比、总内存使用量的数据。
正如
浏览 2提问于2012-01-04得票数 2
回答已采纳
我有一个自定义的SharePoint Designer审批工作流，它在20-30分钟后重新启动(仅针对文档库中的几个实例)，因此工作流失败，因为我正在检查几个条件。我们已经测试了这个工作流，它在大多数实例中都运行得很好。有人告诉我，这可能是由于服务器负载和工作流历史记录项目超过2000个项目造成的。因此，我确保工作流历史记录项目少于500个。但它仍然会重新启动。库中的工作流实例数量约为150个。<e
浏览 0提问于2011-12-13得票数 0
我对Apache Camel和EIP非常有经验，正在努力理解如何在Nifi中实现等价物。我知道Nifi使用了一种不同的范式(基于流的编程)，但我不认为我尝试做的事情是不合理的。简而言之，我希望将每个文件的内容发送到多个rest服务，并希望将响应聚合到单个文档中，该文档将存储在elasticsearch中。我可能还会做一些进一步的处理和清理，以改进存储的内容(但这不是我当前的
浏览 30提问于2018-08-24得票数 2
回答已采纳
当Kinesis流使用者遇到错误，并在使用@StreamListener注释的方法中抛出异常时，如何配置绑定以使消息重新排队或发送到DLQ？我在Spring Cloud Stream中看到了对Rabbit和Kafka的这种级别的支持，但我没有看到对Kinesis绑定的支持。在Kinesis流处理器中处理错误的推荐方法是什么？它是如何通过配置和/或代码实现的</em
浏览 24提问于2019-05-16得票数 1
回答已采纳
我希望使用NiFi rest将流文件传输到输入端口。我正在浏览NiFi rest文档，发现似乎有实现相同目标的支持。然而，诚实并不是很清楚，也不是很详细。我的工作流程如下：源处理器组中的：
目标处理器组中的：
我想知道的是如何将排队的流文件从源处理器组传输到目标处理器组的输入端口，
浏览 2提问于2017-04-05得票数 0
对于不同的nvidia显卡，在不同的流多处理器数量和不同的处理器核数的情况下，每个流处理器具有不同的特性。
所述线程块根据设备的容量分配给单个处理器，如1块32翘曲或2块16翘曲。但我无法理解每个流处理器的核心数目。在每个流处理器中具有较大数目的核的
浏览 3提问于2014-04-22得票数 4
回答已采纳
在我的NiFi管道中，我有一些流文件，在ExecuteStreamCommand处理器上运行一个Python时遇到了问题。当它们失败时，它们会以0字节流文件的形式出现，因此我无法查看和查看可能导致问题的原因以及如何修复它。幸运的是，流文件不只是永远消失了:它与大约6000万其他文件一起存在于S3中。但是，我不想从S3中重新提取大量文件，必须手动梳
浏览 2提问于2019-11-13得票数 0
回答已采纳
我有一个生产环境，可以处理多个数据源的大量数据流。目前，我使用windows消息队列中排队的数据实时解析数据。我在某处读到，任何给定队列中的最大数量都是10000。我担心的是，随着数据量的增加x 100，我将增加流的数量x 10。当然，我的处理需要能够扩展，我不确定当前的设置是否可行。我当前的机器和开发环境：
Visual st
浏览 3提问于2012-10-05得票数 0
我正在windows服务器上运行MiNiFi，该服务器位于公司防火墙后面。我的NiFi正在Hortonworks集群上运行(3个节点(例如: sj47 46、sj47、sj48)。MiNiFi版本: 0.4
在MiNiFi中，我有ListFile处理器、FetchFile处理器和RemoteProcessGroup。但是如果我尝试在MiNiFi和NiFi上打电话，它就没有建立起来。org.apach
浏览 1提问于2019-03-28得票数 2
我正在努力学习如何编写自定义的Nifi处理器，并且从文档中，处理器应该是线程安全的。我想要理解的是，如果-我有100个流文件记录连接到我的自定义处理器，那么我的处理器的onTrigger方法(假设我没有在这个方法上启用@TriggerSerially )会被触发100次并在100个单独的线程中被触发(不管并发与否)，或者是否有可能将一个流
浏览 0提问于2018-12-08得票数 0
回答已采纳
我的工作流程如下。ListenHTTP(我在这里得到一个目录名)-> SplitText ->ExtractText(添加为属性的目录名)
在此之后，我必须使用该属性目录名，并提取该本地dir中的所有文件，并将其放入我知道GetFile/ListFile可以做到这一点，但是我们如何为处理器提供一个动态目录名呢？
浏览 3提问于2017-10-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
