如何在NiFi中将CSV文件指定列的所有值替换为NULL？

方案一：使用Update Record处理器（推荐，适合结构化数据处理） #

你之前用Update Record失败，大概率是Reader/Writer配置或Record Path规则有误，以下是正确配置步骤：

1. 配置CSVReader

   • 设置Header Line Count为1，让处理器识别表头字段
   • 开启Trim Fields为true（处理原数据中字段前后的空格）
   • Schema Access Strategy选择Use Header Fields，自动从表头获取column1、column2字段名

2. 配置CSVRecordSetWriter

   • 设置Header Line Count为1，保留输出表头
   • 将Null Value Representation设为NULL（关键：确保空值输出为字符串NULL）
   • 同样开启Trim Fields为true，保持输出格式整洁

3. 配置Update Record处理器

   • 关联上述配置好的CSVReader和CSVRecordSetWriter
   • Update Strategy选择RECORD_PATH
   • 在Record Path Values中添加规则：
     • Record Path: /column1
     • Value: null（或${null}，NiFi表达式语言中表示空值，Writer会自动转成配置的NULL字符串）

方案二：使用ReplaceText处理器（适合快速文本替换） #

如果不需要解析结构化记录，可以用文本正则替换直接处理：

• 设置Search Value为(?m)^(?!column1,)([^,]+),
  • 正则解释：(?m)开启多行模式，(?!column1,)跳过表头行，([^,]+),匹配每行第一个逗号前的内容
• 设置Replacement Value为NULL,
• Replacement Strategy选择Replace All

这样就能精准替换所有数据行的column1值为NULL，同时保留原文件的格式。

内容的提问来源于stack exchange，提问作者joginder bhardwaj