将 NiFi 中同一列中的字符串值替换为整数值

我想更换一个'字符串值' 并将该值输入为整数值使用 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处理器和配置/启用读者/作家控制器服务

• Add 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 解析器.