2

我们每 10 秒将每个应用程序的消息计数写入 InfluxDb。如果该数字在过去 15 分钟内未更改,我希望能够生成警报。

我尝试了导数,但这给出了每个数据点的变化。单位参数只是缩放结果。Derivative 适用于我们的聊天应用程序,我们可以检查是否每 10 秒发送一次消息,但 15 分钟窗口不起作用。

我尝试将 spread 与按时间分组的批处理查询一起使用,但这给了我整整一刻钟的变化(00 到 15、15:01 到 30、30:01 到 45...)。我希望能够检查最后 15 分钟并每隔一分钟左右检查一次。

我尝试使用带有传播的窗口流,但它似乎在窗口外抓取点,因为它给出了一个非零的答案。

4

0 回答 0