如何清除NiFi队列? [英] How to clear NiFi queues?

问题描述

我们正在 NiFi 中创建一些流，在某些情况下，队列可能正在建立，但由于某种原因，流无法按预期工作.

We are creating some flows in NiFi and there might be some cases where the queues are being build up but due to some reason the flow doesn't work as expected.

归根结底，我想清除队列，并想以某种方式使其自动化.问题是我们如何从后端删除队列?有什么方法可以实现吗?

At the end of the day, i would like to clear the queues and somehow would like to automate it. The question is how can we delete the queues from backend? Is there any way we can achieve that?

推荐答案

除了 Bryan 提到的明确的Drop Queue"功能之外，您可能感兴趣的其他几个功能是Back Pressure"和FlowFile Expiration"设置在连接上.这些允许您自动控制任何给定连接中的数据量.下面是每个的简单解释，但要获得更详细的解释，我建议您参阅 Apache NiFi 用户指南

In addition to the explicit "Drop Queue" function Bryan mentioned, a couple other features you may be interested are the "Back Pressure" and "FlowFile Expiration" settings on connections. These allow you to automatically control the the amount of data in any given connection. A simple explanation for each is below but for a more detail explanation I'd refer you to the Apache NiFi User Guide

背压:当队列达到一定大小时，停止触发提供它的处理器.

Back Pressure: When a queue gets to a certain size, stop triggering the processor that feeds it.

FlowFile 过期:一旦 FlowFile 在队列中花费了 X 时间，它将被丢弃.

FlowFile expiration: Once a FlowFile has spent X amount of time in the queue, it will be dropped.

这篇关于如何清除NiFi队列?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！