在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的属性,其值为当前的时间戳。