Swa*_*ood 5 queue clear apache-nifi
我们正在NiFi中创建一些流程,并且可能在某些情况下队列正在建立,但由于某种原因流量不能按预期工作.
在一天结束时,我想清除队列,并以某种方式想要自动化它.问题是我们如何从后端删除队列？有什么办法可以实现吗？
除了Bryan提到的显式"丢弃队列"功能外,您可能感兴趣的其他一些功能还包括连接上的"Back Pressure"和"FlowFile Expiration"设置.这些允许您自动控制任何给定连接中的数据量.以下是对每种方法的简单解释,但是为了更详细的说明,我将向您推荐Apache NiFi用户指南
背压:当队列达到一定大小时,停止触发为其提供的队列.
FlowFile到期:一旦FlowFile在队列中花费了X个时间,它就会被删除.
在Apache NiFi UI中,如果右键单击队列,则可以选择清空队列.您可以在UI中执行的任何操作都由REST服务支持,因此请查看REST API文档:
https://nifi.apache.org/docs/nifi-docs/rest-api/index.html
特别是对/ flowfile-queues/{id}/drop-requests的POST.
您还可以在使用应用程序时使用Chrome和打开开发人员工具,以查看执行某些操作时对REST API的调用.