The following query computes number of metrics written in a given hour
select time, workflow, metrics_written,
CAST(TO_CHAR(time, 'YYMMddHH24') as BIGINT) as bin,
min(metrics_written) over w, max(metrics_written) over w
from internal_write
where workflow = 'workflow_name'
and output = 'sql'
window w as (PARTITION BY CAST(TO_CHAR(time, 'YYMMddHH24') as BIGINT)
ORDER BY time DESC RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
order by time desc
This one in turn shows number of metrics written within passing 5 minutes window
select time, metrics_written,
max(metrics_written) over w - min(metrics_written) over w as metrics_written_within_5_minutes
from internal_write
where workflow = 'workflow_name'
and output = 'sql'
window w as (order by time range (interval '5 min') preceding)
order by time desc
Brak komentarzy:
Prześlij komentarz