NiFi调用HTTP API后,如何在调用HTTP API之前获取原始流文件

vik*_*ram 5 apache-nifi

我按以下顺序调用rest API。

生成FLowfile处理器-> jsonpath处理器->文本替换处理器(用于后期数据创建)---> InvokeHTTP --->属性的XPATH处理器--->由生成流文件生成的原始流文件。

因此,在文本替换处理器之后,原始数据将被新数据替换。因此,如何获取原始数据并使用调用API后产生的属性。

And*_*ndy 1

您可以使用直接输出关系维护原始流文件,并稍后使用模式碎片整理保留所有唯一属性合并GenerateFlowFile流文件,或者如果原始流文件内容足够小,您可以在更改流文件内容之前将其移动到属性然后在收到新数据后用/重新组合它们。MergeContentUpdate AttributeReplaceText