在Apache NiFi中,可以使用UpdateAttribute
处理器来添加或修改属性的值,以跟踪数据溯源时间。下面是一个示例解决方法:
UpdateAttribute
处理器添加到流程中。UpdateAttribute
处理器的属性面板中,将"User-Defined Properties"设置为以下值:
source.timestamp
:设置为${now():toNumber()}
UpdateAttribute
处理器的输入连接到要进行数据溯源的处理器。UpdateAttribute
处理器。source.timestamp
的属性,其值为当前的时间戳。以下是一个示例的NiFi流程配置:
[Input Processor] -> [UpdateAttribute] -> [Output Processor]
在UpdateAttribute
处理器的属性面板中,配置如下:
User-Defined Properties:
- source.timestamp: ${now():toNumber()}
这将在每个流经UpdateAttribute
处理器的数据上添加一个名为source.timestamp
的属性,其值为当前的时间戳。