Nifi Flowfile进度

Question

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

谢谢

Answer 1

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

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

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

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