在 WSO2 流处理器中比较批次的平均值

Question

我用 Siddhi 编写了一些代码，logs/prints 一批最后 100 个事件的平均值。所以事件 0-100、101-200 等的平均值。我现在想将这些平均值相互比较以找到某种趋势。首先，我只想看看对于一定数量的平均数，是否存在一些简单的上升趋势下降趋势。例如，我想将所有平均值与所有即将到来的 1-10 平均值进行比较。

我查看了 Siddhi 文档，但没有找到我想要的答案。我尝试了一些分区解决方案，但这没有用。下面的代码是我现在拥有的。

define stream HBStream(ID int, DateTime String, Result double);

@info(name = 'Average100Query')
from HBStream#window.lengthBatch(100)
select ID, DateTime, Result, avg(Result)
insert into OutputStream;

Answer 1

Siddhi 序列可用于匹配平均值和识别趋势，https://siddhi.io/en/v5.1/docs/query-guide/#sequence

from every e1=HBStream, e2=HBStream[e2.avgResult > e1.avgResult], e3=HBStream[e3.avgResult > e2.avgResult]
select e1.ID, e3.avgResult - e1.avgResult as tempDiff
insert into TempDiffStream;

请注意，您必须使用分区来确定每个 ID 的模式，因为您需要计算每个传感器的平均值。在您的应用中，如果您需要每个传感器的平均值，也可以使用 group by

@info(name = 'Average100Query')
from HBStream#window.lengthBatch(100)
select ID, DateTime, Result, avg(Result) as avgResult
group by ID
insert into OutputStream;

在 WSO2 流处理器中比较批次的平均值

Compare batches of average values with each other in WSO2 Stream Processor

wso2

siddhi

stream-analytics

streaming-analytics