Apache Nifi:UpdateRecord 替换子值
创始人
2024-09-04 13:31:10
0

以下是一个使用Apache Nifi的UpdateRecord处理器来替换子值的示例代码:

首先,你需要创建一个UpdateRecord处理器,并将其配置为使用RecordPath和ReplacementValue进行子值替换。假设你想要将JSON数据中的"name"字段值替换为"new_name",你可以按照以下步骤进行配置:

  1. 在UpdateRecord处理器的属性中,将"Replacement Strategy"设置为"Record Path Value"。
  2. 在"Record Reader"属性中,选择适合你的数据格式的RecordReader控制器服务(如JsonTreeReader)。
  3. 在"Record Writer"属性中,选择适合你的数据格式的RecordWriter控制器服务(如JsonRecordSetWriter)。
  4. 在"User-Defined Properties"属性中,添加一个新的属性,名称为"record.path",值为"/name",这是要替换的子值的路径。
  5. 添加另一个名为"record.value"的属性,值为"new_name",这是要替换的子值的新值。

完成配置后,你可以将输入数据流连接到UpdateRecord处理器,并将处理结果发送到下一个处理器或输出流。

以下是一个基于Apache Nifi的示例代码: