time - apache nifi 总执行时间

Question

我想知道如何找出/捕获 Apache Nifi 中任何流的总执行时间。有没有办法做到这一点并将其添加到属性列表中，以便可以通过 PutEmail 共享相同的内容？

Answer 1

我相信您必须在收到流文件时添加自定义时间戳属性，进行大部分处理，然后计算要包含在电子邮件中的耗时属性。您可以使用两个 UpdateAttribute 处理器来执行此操作。

更新属性，收到 = ${now():toNumber()}

(做加工)

更新属性，已过 = ${now():toNumber():minus(${received}):format("HH:mm:ss")}

这将格式化耗时，如“00:04:16”(4 分 16 秒)。您可以将其用作 ${elapsed}在您的 PutEmail 消息内容中。

但这有点难看，只给出了处理时间的近似值。 NiFi 出处系统维护“Lineage Duration”，它描述了自文件进入 NiFi 以来耗时。这是一个更权威的数字。但我不相信你可以从表达语言中查询谱系持续时间。您将不得不单独查询和分析出处数据。