阿帕奇尼菲。在现有的基础上添加新的 CSV 字段并进行修改

Apache NiFi. add new CSV field based on existing with modification

我有包含多个字段的 .csv 文件。其中之一(例如第 3 个)包含电子邮件。如何添加仅包含来自电子邮件字段的服务器名称的附加文件?

示例:

输入:

01;城市;姓名@servername.com;年龄;

结果:

01;城市;姓名@servername.com;年龄;服务器名;

我想可以通过 ReplaceText 处理器实现,但我无法在“搜索值”和“替换值”字段中选择正确的值。

您可以在 ConvertRecord 的帮助下将流文件转换为记录。 它允许您将 JSON (或其他格式)传递给您喜欢的任何格式。 然后您可以添加一个新字段,如下所示,带有 UpdateRecordProcessor:

我推荐你阅读以下内容: