在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，这是一篇非常相似的文章，描述了解决在CSV上添加新列的方法：

Apache NiFi: Add column to csv using mapped values

最简单的方法是ReplaceText，将相同的“ | 20-10-2020”附加到每一行。 ReplaceText设置将逐行和Regex计算：$ 1 | 20-10-2020。其他方法是更动态地执行此操作的其他方法，例如，如果日期不是静态的。