Apache Nifi: 使用Update Record处理器替换列中的值
创始人
2024-09-04 12:30:35
0

在Apache Nifi中使用UpdateRecord处理器来替换列中的值,可以按照以下步骤进行操作:

  1. 首先,将输入数据流连接到UpdateRecord处理器。在UpdateRecord处理器的属性设置中,将Record Reader属性设置为适合你输入数据格式的记录读取器,将Record Writer属性设置为适合你输出数据格式的记录写入器。

  2. 在UpdateRecord处理器的属性设置中,找到Replacement Value Strategy属性,并选择适合你的替换策略。有几种替换策略可供选择,例如Literal Value(字面值)、Record Path Value(通过记录路径获取值)等。

  3. 然后,为每个要替换的列配置替换规则。在UpdateRecord处理器的属性设置中,找到UpdateRecord属性,并点击“+”按钮以添加新的替换规则。

  4. 对于每个替换规则,设置以下属性:

    • RecordPath: 指定要替换的列。可以使用类似于JSONPath的记录路径表达式。
    • Replacement Value: 设置要替换的新值。根据你选择的替换策略,可以是字面值、记录路径表达式等。

以下是一个示例配置,演示如何使用UpdateRecord处理器替换列中的值:

{
  "name": "John",
  "age": 30,
  "gender": "Male"
}

配置示例:

Replacement Value Strategy: Literal Value

UpdateRecord (1)
  - RecordPath: /name
  - Replacement Value: "Mike"

UpdateRecord (2)
  - RecordPath: /age
  - Replacement Value: "${age:toNumber():multiply(2)}"

UpdateRecord (3)
  - RecordPath: /gender
  - Replacement Value: "${gender:toUpper()}"

根据上述配置,将替换规则应用于输入数据后,输出数据将如下所示:

{
  "name": "Mike",
  "age": 60,
  "gender": "MALE"
}

在这个示例中,UpdateRecord处理器使用字面值替换了"name"列的值,使用记录路径表达式${age:toNumber():multiply(2)}替换了"age"列的值,使用记录路径表达式${gender:toUpper()}替换了"gender"列的值。

相关内容

热门资讯

9分钟指南书!九天大厅挂价格,... 9分钟指南书!九天大厅挂价格,新祥心辅助脚本(辅助)一贯真的是有辅助(哔哩哔哩)一、新祥心辅助脚本可...
第十分钟窍要!杭麻圈辅助工具,... 第十分钟窍要!杭麻圈辅助工具,天酷游戏交易平台(辅助)原来是有辅助(哔哩哔哩)1、完成天酷游戏交易平...
第六分钟举措!四川游戏家园手机... 第六分钟举措!四川游戏家园手机版辅助,三哥玩app辅助(辅助)果然有挂下载(哔哩哔哩)1、金币登录送...
第八分钟攻略!金州水鱼脚本,新... 第八分钟攻略!金州水鱼脚本,新九五有没有脚本(辅助)果然有挂软件(哔哩哔哩)1、让任何用户在无需新九...
第六分钟秘籍!天天川南辅助,超... 第六分钟秘籍!天天川南辅助,超级三加一辅助工具(辅助)果然是真的安装(哔哩哔哩)1、超级三加一辅助工...
第七分钟教程书!拼三张辅助器,... 第七分钟教程书!拼三张辅助器,海贝之城辅助软甲下载(辅助)原来真的有平台(哔哩哔哩)1、用户打开应用...
第五分钟指引!蜀渝牌乐汇挂机软... 第五分钟指引!蜀渝牌乐汇挂机软件,天酷辅助巡查系统(辅助)果然真的是有安装(哔哩哔哩)该软件可以轻松...
8分钟讲义!微友辅助器免费版v... 8分钟讲义!微友辅助器免费版v2.0,新财神正版辅助挂(辅助)真是真的是有辅助器(哔哩哔哩)1、8分...
8分钟策略!椰岛长胜辅助,随意... 8分钟策略!椰岛长胜辅助,随意玩聚乐部辅助(辅助)本来是有插件(哔哩哔哩)1、该软件可以轻松地帮助玩...
2分钟课程!陕麻圈是不是可以作... 2分钟课程!陕麻圈是不是可以作必弊,蜜蜂大厅辅助插件(辅助)一直真的是有软件(哔哩哔哩)1)陕麻圈是...