通过 REST API 以编程方式删除队列中的流文件

deleting flowFiles in queues programatically by REST API

我想清除 'response' 队列和任何其他队列,如果处理器因故障而停止(我用 'template' 停止它,其工作方式类似于休息 api) . 我读过这个:https://nifi.apache.org/docs/nifi-docs/rest-api/index.html 但我不知道如何使用它来实现我的想法。

  1. 我的意思是,如果我可以清除响应队列,那将是完美的,以防万一,我 故障队列中至少有 1 个流文件。可能吗?
  2. 我可以使用 Put 请求删除队列吗?我的意思是队列中的流文件是否有任何状态可将其设置为空或已删除?

使用浏览器的开发人员工具 window,使用 UI 在监视网络选项卡时清除队列。 Apache NiFi UI 所做的一切都是通过 REST API 执行的。您将能够准确地看到向服务器发送了哪些请求以清除连接队列,并可以通过编程方式重新创建连接队列。

在这种情况下,您需要的特定 API 端点是 POST /flowfile-queues/{id}/drop-requests,其中 {id} 是连接 ID。