NiFi字符串操作函数可以在QueryRecord中使用吗？

Question

可以在queryRecord SQL语句字段中使用子字符串或concat函数吗？看到我有流文件{ "field1": "1, Tom Johnson", "field2":"3", "field3":"xyz" }在QueryRecord处理器SQL查询是，

select substringAfter(/field1, ',') as NAME, substringBefore(/field2, ',') as ID, field3 from flowfile

，在运行带有有关查询错误的处理器时，我得到了错误。不知道是什么问题。这是如何做到的呢？

上游位于below文件之上，并尝试了sql查询，如下所示：

  select substringAfter(/field1, ',') as NAME, substringBefore(/field2, ',') as ID, field3 from flowfile

和

 select substringAfter(field1, ',') as NAME, substringBefore(field2, ',') as ID, field3 from flowfile

处理器不接受路径为/field1的查询。在准备SQL语句期间，第二次触发运行时错误。那么，这些NiFi函数可以用于QueryRecord吗？

Answer 1

您可以使用UpdateRecord处理器来完成此操作。

​

​

之后您需要清理剩余的字段，但是可以用QueryRecord来完成：

从FLOWFILE

中选择名称、ID、field3