使用 groovy 在 apache-nifi 中使用 executescript 处理器更新 csv 值失败

Question

此问题与this SO question有关

以上解决方案解决了我的问题，现在我尝试将其连接到来自QueryRecord 处理器的流中。

这里QueryRecord 将我的流文件分成两个流。让我们说customers 和suppliers。而ExecuteGroovyScript用于添加ORDER和COMPLAINT。

示例 csv：

id,record_type
1,0
2,0
3,1

所以结果应该是：

id,record_type
1,ORDER
2,ORDER
3,COMPLAINT

实际结果只是放置了默认'IGNORE'值。

QueryRecord 配置

QueryRecord csv 写入模式。

Answer 1

如果您只想简单地更新字段值，请使用UpdateRecord 处理器。

当您输入如下文本时：

id,record_type
1,0
2,0
3,1

然后将记录阅读器设置为CSVReader，并将Schema Access Strategy 选项设置为Use String Fields From Header。作家不是问题。 UpdateRecord 处理器属性如下所示：

Record Reader               CSVReader
Record Writer               CSVRecordSetWriter
Replacement Value Strategy  Literal Value
/record_type                ${field.value:replace('0','ORDER'):replace('1','COMPLAINT')}

这将给出您预期的结果。