在末尾添加列到 NiFi 中的管道分隔文件
Adding column at the end to pipe delimited file in NiFi
我在 SFTP 服务器中有这个特殊的竖线分隔文件
PROPERTY_ID|START_DATE|END_DATE|CAPACITY
1|01-JAN-07|31-DEC-30|101
2|01-JAN-07|31-DEC-30|202
3|01-JAN-07|31-DEC-30|151
4|01-JAN-07|31-DEC-30|162
5|01-JAN-07|31-DEC-30|224
我需要使用 NiFi 将此数据传输到 S3 存储桶。在这个过程中,我需要在最后添加另一列今天的日期。
PROPERTY_ID|START_DATE|END_DATE|CAPACITY|AS_OF_DATE
1|01-JAN-07|31-DEC-30|101|20-10-2020
2|01-JAN-07|31-DEC-30|202|20-10-2020
3|01-JAN-07|31-DEC-30|151|20-10-2020
4|01-JAN-07|31-DEC-30|162|20-10-2020
5|01-JAN-07|31-DEC-30|224|20-10-2020
在 NiFi 中实现这个的简单方法是什么?
@Naga 这里有一个非常相似的post,它描述了解决在 CSV 上添加新列的方法:
最简单的方法是 ReplaceText 将相同的“|20-10-2020”附加到每一行。 ReplaceText 设置将逐行评估,正则表达式:$1|20-10-2020。其他方法是更动态地执行此操作的其他方法,例如,如果日期不是静态的。
我在 SFTP 服务器中有这个特殊的竖线分隔文件
PROPERTY_ID|START_DATE|END_DATE|CAPACITY
1|01-JAN-07|31-DEC-30|101
2|01-JAN-07|31-DEC-30|202
3|01-JAN-07|31-DEC-30|151
4|01-JAN-07|31-DEC-30|162
5|01-JAN-07|31-DEC-30|224
我需要使用 NiFi 将此数据传输到 S3 存储桶。在这个过程中,我需要在最后添加另一列今天的日期。
PROPERTY_ID|START_DATE|END_DATE|CAPACITY|AS_OF_DATE
1|01-JAN-07|31-DEC-30|101|20-10-2020
2|01-JAN-07|31-DEC-30|202|20-10-2020
3|01-JAN-07|31-DEC-30|151|20-10-2020
4|01-JAN-07|31-DEC-30|162|20-10-2020
5|01-JAN-07|31-DEC-30|224|20-10-2020
在 NiFi 中实现这个的简单方法是什么?
@Naga 这里有一个非常相似的post,它描述了解决在 CSV 上添加新列的方法:
最简单的方法是 ReplaceText 将相同的“|20-10-2020”附加到每一行。 ReplaceText 设置将逐行评估,正则表达式:$1|20-10-2020。其他方法是更动态地执行此操作的其他方法,例如,如果日期不是静态的。