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

Question

我有一个 CSV 文件，其中包含 ID、姓名和薪水作为字段。我的 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 输出。