Nifi Flowfile进展

我正在试图找出一个人可以做什么来查看一个流文件在http通过nifi流的位置 . 例如,假设我有一个用户可以上传文件的网页 . 我想向用户表明该文件当前正在被摄取/处理,并且可能是其所处的阶段 . 我可以利用nifi提供什么来获取这些信息?就像有没有办法看到流文件经过哪些处理器,或者它目前处于哪个处理器/队列?

谢谢

回答(1)

2 years ago

一种选择是使用NiFi的起源事件并为流文件UUID发出起源查询,以查看所有当前事件,这些事件应该为您提供已经通过的所有处理器的图表:

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

您可以在UI中使用种源功能打开Chrome Dev Tools,并查看对REST API进行的调用 .

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