Influxdb output error handling

Hi,

  1. 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.

  2. In my flows, I use a catch node which is tied only to the influx-batch node (not "all nodes"), so the msg.payload object 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.

1 Like