我想实现一个简单的用例,使用 NiFi 将 CSV 内字段中的多个字符串/文本值更新为整数值。例如,我的 CSV 文件如下所示:
输入 CSV 文件:
字段_1、字段_2
美国,苹果
美国,苹果
印度, 葡萄
中国城,奥兰治
澳大利亚民族,桃子
印度, 葡萄
中国城,奥兰治
所以我希望输出 CSV 如下:
输入 CSV 文件:
字段_1、字段_2
1, Apple
1, Apple
4、葡萄
3、橙子
2, Peach
4、葡萄
3、橙子
我希望将 Field_1 中的所有美国更新为 1,将澳大利亚国家更新为 2,将中国城更新为 3 等等...我能够使用以下命令仅更新一个值更新记录处理器使用替代价值策略作为“字面替换”。请参见下面的附图:
但我无法更新 Field_1 中的剩余值,例如中国、印度等。我知道我可以复制多个 UpdateRecord 处理器来实现此目的,但我想仅使用一个处理器来实现此用例。我怎样才能使用一个处理器来做到这一点?如果是的话,需要在 NiFi 中设置什么配置来实现这一点?
先感谢您。任何帮助深表感谢。
Use QueryRecord
处理器(使用类似 Sql 的 case when 语句)
(or)
LookupRecord
处理器通过定义SimpleKeyValueLookupService
参考this https://stackoverflow.com/questions/53876754/replace-string-value-to-integer-value-in-nifi-within-a-same-column/ and this https://community.hortonworks.com/questions/113845/how-to-use-simplekeyvaluelookupservice-processor-i.html类似问题的链接。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)