如何在Nifi ReplaceText处理器中用属性值替换文本?

uma*_*ang 3 replace apache-nifi

我想用属性说var1的属性值123(如图所示)替换flowfile(基于我拥有的rgex)的某些内容。我正在使用Nifi中的“替换文本处理器”来执行此操作,但是不会替换内容,而是会删除流文件。

数据流的图像

Jag*_*rma 8

您可以使用以下流程作为示例来实现正则表达式替换。

在此处输入图片说明

各个处理器配置如下:

GenerateFlowFile:这将生成包含某些内容的流文件。在这种情况下,内容为This is my content

在此处输入图片说明

UpdateAttribute:这将添加一个具有key = var1和value = 的属性123

在此处输入图片说明

ReplaceText:这将查找正则表达式的匹配项,并替换为attribute的值var1。因此,This is my content将转换为This is my 123

在此处输入图片说明

OriginalContent:这是替换之前看到的实际内容。它使用PutFile处理器。

在此处输入图片说明

UpdatedContent:这是查看更新的内容。它使用PutFile处理器。

在此处输入图片说明

验证

该流运行了一次之后,您可以通过查看生成的文件来验证内容。

$ cat original/5601958271012409 
This is my content

$ cat updated/5601958271012409 
This is my 123
Run Code Online (Sandbox Code Playgroud)