Skip to main content

UpdateRecord

根据输入数据流来更新指定字段或新增指定字段

参数说明​

读取服务​

指定读取数据流内容的数据格式

写入服务​

指定输出内容的数据格式

值替换策略​

指定通过何种方式来配置替换值或更新值

  • 字面值
  • RecordPath值

自定义属性​

指定替换值或新增值的内容

输出连线​

  • failure连线表示无法将数据流从配置的输入格式转换成配置的输出格式数的数据流输出
  • success连线表示成功将数据流从配置的输入格式转换成配置的输出格式数的数据流输出

示例​

GenerateFlowFile配置​

为避免生成过多数据，将组件”调度“中的”运行安排“设置为7 days。

再将”自定义文本“设置为：

ID,USERNAME,NAME,AGE,BIRTHDAY
1,zhangsan1,张三,20,1998-08-01  00:00:00.0
2,lisi,李四,21,1997-08-01  00:00:00.0
3,wangwu,王五,33,1985-08-08  00:00:00.0
4,zhaosi,赵四,45,1973-08-01  00:00:00.0
5,zhaosi,赵四,43,1975-08-01  00:00:00.0
6,qiansheng,钱生,43,1975-08-01  00:00:00.0
7,zhaoai,赵爱,43,1975-08-08  00:00:00.0
8,zhaotang,赵唐,33,1985-09-01  00:00:00.0
9,zhaosi,赵四,45,1973-09-09  00:00:00.0
10,zhaoai,赵爱,43,1975-09-01  00:00:00.0
11,zhaobi,赵璧,45,1973-02-03  00:00:00.0
12,zhaori,赵日,44,1974-03-03  00:00:00.0
13,zhaosi,赵四,45,1973-09-09  00:00:00.0
14,zhaotang,赵唐,33,1985-09-09  00:00:00.0
15,zhaotc,赵唐,43,1975-09-01  00:00:00.0

流程说明​

在此流程中会通过读取CSV数据，将其转换为JSON输出，在此同时，会更新USERNAME字段，将该字段的值更新为ID+NAME

UpdateRecord设置​

以更新UserName字段为例，设置了读取服务为CSV读取控制器服务，写入服务为JSON输出控制器服务，值替换策略选择RecordPath值，新增一个属性/USERNAME为"concat(/ID,' ',/NAME)"。

结果​

最后输出结果如下：

  • success连线输出结果

流程模板​

参见附件(请右键另存保存)：模板文件