NiFi中漏斗的目的

Vas*_*ian 6 apache-nifi

NiFi UI - 截图

在图像中,有 3 个GenerateFlowFile处理器连接到一个LogAttribute处理器。我想知道漏斗的必要性。请说清楚。

我了解漏斗的一种此类用途,它可用于合并来自此youtube视频中所述的两个不同进程组的组件。

Ben*_*obi 10

好吧,想象一下有 20 个这样的GenerateFlowFile处理器。想象一下必须LogAttribute用不同的处理器更换处理器。这将是一项艰巨的工作,因为它们直接连接到LogAttribute处理器。但是,如果它们之间有漏斗,则只需替换漏斗的目的地,而不是所有处理器。

我也用它来调试流程。当我需要一个快速的目的地来测试流的中间结果时。

基本上漏斗所做的就是在获取 FlowFiles 时将它们向前传输。