如何在 Apache NIFI 的流的最后一个处理器中使用第一个处理器输入/输出而不存储文件/数据库

Question

我有 5 个处理器 处理器1(have a value)=>处理器2(have b value) => 处理器3(calculate c=a+b)=>处理器4(calculate d=c*a)=>处理器5(calculate e=d*b)。 我将在处理器 4 中使用处理器 1 的值，在处理器 5 中使用处理器 2 的值。 我需要将输入/输出结果存储在高速缓存处理器 n 中以在处理器 n 中使用。我该如何实现这一点，请建议是否有任何处理器，或者我可以通过 bash 脚本实现这一点吗？

Answer 1

对我来说，这听起来像是一系列 UpdateAttribute 处理器：

UpdateAttribute(a=1, b=2) -> 
UpdateAttribute(c=a + b)  ->
UpdateAttribute(d=a * c)  ->

您将拥有的所有 4 个值作为同一流文件的属性