我应该使用哪个处理器将不同的JSON输入组合到一个对象中?

我想建立一个接收多个JSON输入的数据流,并将它们组合成一个具有多个属性的JSON对象(我目前正在使用一些GenerateFlowFile处理器来生成输入),然后每隔10秒通过PublishMQTT处理器发送数据。

输入以不同的间隔(1-5秒)输入,示例如下:

• {“温度”:60}

• {“压力”:30}

我想把输入的数据编译成一个对象。 {“温度”:60,“压力”:30} 在发送到PublishMQTT处理器之前。

此外,如果具有相同属性的新数据在发送消息之前进入,则应更新相同对象中的属性,而不是排队。i、 e.如果输入新数据 {“压力”:150} ,输出对象应更新为 {“温度”:60,“压力”:150} 在通过MQTT发送之前

我想我需要一个处理器(见附件图片中的蓝色圆圈),但我不确定哪个处理器做了我所描述的。