Fluentd plugin to aggregate count messages with calculation and then thresholding