有没有办法在shell脚本中使用rest api检查处理器组中的所有消息/流文件是否都已清除？ 基本上，我的用例是通过curl命令在shell脚本中停止nifi处理器。然后，我需要等待，直到所有的队列都是空的，流文件已经通过，然后才能继续。
浏览 22提问于2019-04-30得票数 0
1回答
我想知道是否有一种方法可以捕获Nifi上出现的公告消息(基本上是错误)，并将其存储在某个属性/文件中，以便以后可以查看。屏幕每5分钟刷新一次，如果任何处理器出现故障，我想知道原因。
浏览 6提问于2016-05-25得票数 7
回答已采纳
在安装nifi之后，我正在尝试创建一个流来测试hdfs-nifi连接。但我在仪表板上的每次点击都会不断地收到以下错误。 我就是根。因此，我可以完全访问这些组件。 ?
浏览 21提问于2019-01-07得票数 0
我启动了一个apache/nifi容器，构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5提问于2020-09-22得票数 1
我们有多个团队nifi应用程序在同一台nifi机器上运行...有没有办法记录特定于我的应用程序的日志？另外，在默认情况下，nifi-app.log文件很难跟踪问题，公告牌仅在5分钟内显示错误消息...如何在Nifi中捕获错误并发送邮件警报？
请帮我解决这个问题。提前感谢！
浏览 10提问于2019-03-30得票数 3
我使用的是NIFI，我有数据流，其中我使用了以下过程：
两级进程组(如dataflow >>> process group 1 >>> Process group 2 )，我的问题是如何处理错误--在本例中，我为每个处
浏览 1提问于2016-12-20得票数 1
1回答
我有一个NiFi流，在这个流中，我从elasticsearch获取数据，经过一些处理后，我将流文件保存在目标位置。一旦保存了所有的流文件，我希望通知合并进程将文件中的所有数据合并到一个大的csv文件中。我的问题是如何通知合并处理器现在<em
浏览 64提问于2021-08-09得票数 0
1回答
创建包含自定义处理器和一些默认处理器的进程组&将其添加到桶中。用户sys_admin可以添加组到画布和修改它和它的处理器。用户test_user应该只能将它添加到画布中，而不能修改它(或者它的处理器)。用户test_user仅具有对桶的读取权限。但是用户test_user可以添加处理器组，然后进入并修改它。
在桶级有限制访问
浏览 1提问于2019-03-06得票数 0
回答已采纳
我想在某些NiFi处理器中记录故障原因。但我发现它可能有多种原因。SplitAvroJson处理器的示例：“如果FlowFile由于任何原因(例如，FlowFile无效)处理失败，它将被路由到此关系”
是否有可能获得失败的确切原因，以便将其保存在put文件中？
浏览 4提问于2016-04-26得票数 7
我已经创建了3个过程组。我希望在第一个进程组完成后执行第二个进程组，在第二个进程组完成后执行第三个进程组。
对此有什么解决方案吗？
浏览 1提问于2017-01-30得票数 3
为了使流和控制器服务环境不可知(因此从开发阶段-prod移动将很容易)，我使用变量/表达式语言的密码和用户名。并计划从custom.properties文件或进程组变量中读取密码/用户名。因此，希望使用某种形式的加密，然后在所需的处理器中对其进行解密。( NIFI可以在内存中对所有处理器解密吗？)在custom.properties文件
浏览 4提问于2017-10-26得票数 3
回答已采纳
我正在尝试通过Avroschemaregistry验证一个使用ValidateRecord处理器的json。我需要将验证错误消息存储到sql表中，所以我尝试捕获属性中的错误消息，但无法捕获属性中的错误消息，您知道该如何做吗
浏览 45提问于2020-10-12得票数 0
我正在通过一个生成流程文件的Nifi进程组进行工作。我正在尝试更新filename属性，但我注意到一个单引号也被添加到文件中。这确实有效，但当我查看输出时，我看到：当我保持流文件文件名不变时，我看不到引号。以下是我的PutFile设置，几乎是默认
浏览 2提问于2022-04-26得票数 0
回答已采纳
我试图在NiFi (1.11.4)中构建一个流，该流读取来自AMQ的Avro消息，使用对它们进行累加，然后将合并的parquet文件写入HDFS。因此，我尝试使用AvroRecordSetWriter，然后是PutParquet (或ConvertAvroToParquet) )，并面临另一个问题:如果我为拼花文件设置行组大小(例如122MB)，那么小文件
浏览 3提问于2020-09-25得票数 0
我在NiFi中有flow：在将所有的流文件放入HDFS之后，我需要运行shell脚本。我如何知道或检查所有流文件都已处理？
浏览 8提问于2020-06-20得票数 3
我们有一个13节点的nifi集群，拥有大约50k的处理器。flow.xml.gz的大小约为300 is。要建立13个节点的Nifi集群，通常需要8-10小时。最近，我们将集群分为两个部分，5节点集群和8节点集群，它们都具有相同的300 in flow.xml.gz。从那以后，我们无法在这两个星系团中得到Nifi。此外，我们没有看到任何与此问题有关的有效日志。有同样的flow.xml
浏览 2提问于2021-07-22得票数 0
回答已采纳
我想使用被列为受限的NiFi处理器。虽然我已经搜索过信息，但我不太明白它们是如何工作的。我在这里发现了一些信息：
我知道它们是处理器，可以执行代码，因此对系统是不安全的。你需要许可才能使用它们。但我不太明白它们对我的应用程序、数据或NiFi是否不安全。我不太明白这篇文章中的意思：“只有当NiFi已经被保护时，用户才能被限制在NiFi中添加这样的组
浏览 0提问于2021-02-10得票数 0
回答已采纳
1回答
卡夫卡引发的NiFi工作流瓶颈
、、、、
我正在Apache NiFi中创建一个数据摄取工作流，使用Kafka作为缓冲系统。我设置了一个3节点集群，运行相同的工作流，每个节点有4个核心。我依赖于几个将数据移入和移出不同Kafka主题的实例，这是工作流程中最慢的部分，并且在性能方面非常不一致，因为两个相同的测试可以增加高达100%的持续时间。我们的发布和消费Kafka处理器在所有三个节点上运行，并且我们<e
浏览 16提问于2017-08-15得票数 1
回答已采纳
2回答
我已经开始了一个Nifi过程(消费卡夫卡)，并将它与一个主题联系起来。它正在运行，但我无法(不知道)在哪里查看消息？
浏览 0提问于2018-05-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
