在NiFi中取消csv并将其摄取到sqls中

Question

我是新来的。正在尝试将csv文件摄取到sql server，但需要在摄取之前取消激活数据。 例如： 这是原始csv

Name, Maths, Science, English
Raghav, 60, 70, 80
Nisha, 77, 56, 89

sql表的最终输出：

^{pr2}$

如何在NiFi中实现这一点。不需要临时工作台

我尝试过使用熊猫，但在NiFi中不支持

Answer 1

apachenifi可以执行此操作，但您需要编写自定义逻辑并使用ExecuteScript处理器。在

此过程不是泛型和可重复的，因为根据提供的数据，您不知道要在输出中提供新列名的“列”类型。您必须硬编码这些值或从单独的数据源读入它们。在

有许多使用Groovy/Ruby/Python或其他脚本语言执行转置操作的例子，这正是您在这里想要做的。在Groovy中，它是List对象的List上的一个方法，如List#transpose()中所定义。并使用简单的CSV方法将CSV加载到Groovy数据处理中。mattburgess提供了许多示例using the ^{} processor从flowfile读入数据，对其进行操作，并将其写回flowfile内容并将其发送到后续连接。在