使用NiFi读取CSV文件并提取指定字段用于REST查询，需选哪些处理器？

核心处理器组合 #

• GetFile：负责从指定目录读取目标CSV文件，将文件内容转为NiFi的FlowFile。可配置文件过滤规则（如仅处理.csv后缀），以及读取后文件的处理策略（移动、删除等）。
• ConvertRecord：结构化数据处理的核心。需配置CSVReader作为记录读取器，指定列分隔符、是否包含表头；再搭配JsonRecordSetWriter（推荐，方便后续构造REST请求）作为写入器。关键是在Record Paths to Include属性中仅填入first name、last name、date of birth，实现精准字段提取。
• SplitRecord：如果需要将整份CSV拆分为单条记录的FlowFile（适配单条记录发起REST请求的场景），用这个处理器配合CSVReader和对应Writer，把每条记录单独生成一个FlowFile，方便后续逐个处理。
• InvokeHTTP：若后续直接用提取的字段构造REST请求，该处理器可用于发送HTTP请求。通过表达式语言（如${record:first name}）将提取的字段嵌入请求URL或请求体。

补充提示 #

• 如果CSV存在特殊格式（如带引号的字段、转义字符），要在CSVReader中提前配置对应属性，保证记录解析准确。
• 若需对提取字段做简单清洗（去空格、格式转换等），可在ConvertRecord后添加UpdateRecord处理器，通过Record Path表达式修改字段值。

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