Nifi流文件进度

Question

我试图弄清楚如何通过 http 来查看流文件在 nifi 流中的位置。例如，假设我有一个用户可以上传文件的网页。我想向用户表明该文件当前正在被摄取/处理，以及它可能处于哪个阶段。 nifi 提供了什么，我可以利用它来获取这些信息？有没有办法查看流文件经过了哪些处理器，或者它当前所在的处理器/队列？

谢谢

Answer 1

一种选择是使用 NiFi 的出处事件并对流文件 UUID 发出出处查询以查看所有当前事件，这应该为您提供它通过的所有处理器的图表：

https://nifi.apache.org/docs/nifi-docs/html/user-guide.html#data_provenance

您可以在 UI 中使用出处功能时打开 Chrome 开发工具，查看对 REST API 进行了哪些调用。

另一种选择是在您的流程中构建某种状态更新。您可以建立自己的 HTTP 服务来接收简单的事件，例如 id、时间戳和处理器名称，然后在您的流程中，您可以将 InvokeHttp 处理器放置在您想要向服务报告状态的任何位置。然后，您的 UI 将使用它自己的数据库或您存储它们的任何位置中的状态事件。