NIFI 数据转换中的牧马人端口是什么?

what is wrangler port in data transformation in NIFI?

我想知道 DATA TRANSFORMATION 模板中的 Wrangler input/cleanup 端口是什么。对于提供输入和清理端口的数据摄取模板 nifi,我们可以在其中定义属性、目录和所有内容。

但是当涉及到数据转换时,无法理解什么是 Wrangler 端口,我们从哪里获取数据进行转换以及 table 从数据源中使用了哪些。

请提供您的建议/链接/资源。

谢谢

to-wrangler-port 和 to-wrangler-cleanup-port 端口是 NiFi 输出端口。它们允许在进程组之间连接处理器。在数据转换可重用模板流程中,它们分别连接到 wrangler-input-port 和 wrangler-cleanup-port NiFi 输入端口。

Kylo 中的Data Transformation 模板实际上包含两个NiFi 模板。第一个 NiFi 模板包含来自您的提要的信息,例如转换列表。第二个 NiFi 模板包含所有数据转换提要使用的处理器。这鼓励可重用性,并更容易确保遵守业务策略。

Kylo 团队有一个 "Connecting to a Reusable Flow" 视频更详细地解释了这些概念: https://kylo.io/tutorials.html https://www.youtube.com/watch?v=Vj641MRJCd8