我想更换一个'字符串值' 并将该值输入为整数值使用 Nifi ReplaceText。我不知道如何在 NiFi 中实现这一点。
所以我的场景如下：
我将有一个 CSV 文件，其中包含几个带有整数的字段和几个作为字符串总值的字段。对于具有字符串值的字段，我想将其作为预定义的整数插入到我的数据库表中。例如： 我的 CSV 如下所示：
字段 1、字段 2、字段 3、字段 4、字段 5
1,2,abc,45,John
23,12,pqr,28,Sam
98,75,lmn,87,Smith
所以现在在 MySQL 表中，Field3 和 Field4 的数据类型为整数，因此在将 CSV 插入数据库之前，我想将字符串值更改为预定义的整数值，即对于 Field3 abc 值应在 MySQL 表中输入为 0，pqr 作为 1，lmn 作为 2 等等...类似地，Field4 中的值应在 MySQL 表中输入为 John 作为 10，Sam 作为 20 和 Smith为 30...所以我的上述 csv 应按如下方式存储在我的数据库中：
字段 1、字段 2、字段 3、字段 4、字段 5
1,2,0,45,10
23,12,1,28,20
98,75,2,87,30
我想我可以用 ReplaceText 来实现这一点。但如果有更好的方法来实现这一目标那就太好了。因为我的 CSV 将有 1000 多个列，假设 50 多个列将有一个字符串值，我需要处理该值并将其转换为预定义的整数值。在NiFi中可以实现这一点吗？
如果是，那么要设置什么配置以及最好的方法是什么？
谢谢你！
Use QueryRecord处理器和配置/启用读者/作家控制器服务
custom sql query作为处理器的新属性查询记录配置：
select Field1,Field2,
CASE WHEN Field3='abc' THEN '0'
WHEN Field3='pqr' THEN '1'
WHEN Field3='lmn' THEN '2'
end Field3,
Field4,
CASE WHEN Field5='John' THEN '10'
WHEN Field5='Sam' THEN '20'
WHEN Field5='Smith' THEN '30'
end Field5
from FLowfile
QueryRecord 处理器的输出流文件将具有您想要的结果
Field1,Field2,Field3,Field4,Field5
1,2,0,45,10
23,12,1,28,20
98,75,2,87,30
Use this供您参考上述流程的模板查询记录处理器用途Apache Calcite sql 解析器.