I was looking before on something similar with batching. On some machine i poll data at a constant rate using OPC-UA and when a specific value is true, i save all tags to the DB. I solve this today using grouping of the data to one json output and node-red to handle the logic. I was looking in to using subscription of the tags an use a buffer in benthos to hold the latest values until the correct tag triggers the writing to db and then writes all the tags using the same timestamp.. This would basically work in the same way as @trentc is requesting. hmm.. maybe i need to write a custom processor for this, since the caching in benthos can be quite complex to setup.