Hi,
-
You could use a batch node (group messages by time interval) paired with a join node to aggregate values over 10s or so, and then create the points for the influx-batch node.
-
In my flows, I use a catch node which is tied only to the influx-batch node (not "all nodes"), so the
msg.payloadobject sent by the catch node will always contain the array of influx points. At the moment I just write these to a file (json node --> file node), which can be imported later.
So whenever a write operation fails, all missing influx points will be stored in the file.