csv - 如何使用 nifi 更新 csv 上特定字段的值？

Question

我有一个 CSV 文件，其中包含 id、name 和 salary 作为字段。我的 CSV 文件中的数据如下所示。

id,name,salary
1,Jhon,2345
2,Alex,3456

我想用新的 id (id*4) 更新当前的 CSV

id,name,salary
4,Jhon,2345
8,Alex,3456

目标中的文件格式应为 CSV。谁能告诉我流程？ (我需要什么处理器)。我对nifi很陌生。非常感谢。

Answer 1

使用具有以下设置的 UpdateRecord 处理器，

Record Reader               CSVReader
Record Writer               CSVRecordSetWriter
Replacement Value Strategy  Literal Value
/id                         ${field.value:multiply(4)}

然后它给出了想要的结果。只是 csv 输入和 csv 输出。