Esper规则语言：使用计时器进行规则

Question

我想在Esper中编写一条规则，当过去15分钟内的步数为0且心率高于120时触发。我想出了以下规则：

EPStatement cepStatementRule8 = cepRule.createEPL("context PartitionByMacSteps select * from "
                + "Steps.win:time(15 min) S, HeartRate.win:time(1 min) H "
                + "having (max(S.steps)-min(S.steps) = 0) and (H.heartrate > 120)");
        cepStatementRule8.addListener(new rule8Listener());

我的心率类别有以下字段：

int heartrate;
String heartratesTimestamp;
String macAddress;

我的Steps类有以下字段：

int steps;
String stepsTimestamp;
String macAddress;

我面临的问题是，我只想在过去15分钟内没有采取任何措施的情况下启动规则。现在，当两个步骤事件的步骤数相同时，它将激发。我知道我可能必须使用计时器。但是我不知道如何写这个规则。谁能帮帮我吗？

Answer 1

要求定义不清。“心率高于120”到底是什么意思，是一次还是15分钟还是1分钟，此外“心率高于120”如何与步数条件重叠或巧合。

我建议将问题分解为两个独立的条件检测，然后进行连接以检测这两个条件是否在某个时间发生。这也使得测试变得很容易，因为您可以看到每个条件都是单独指示的。例如，大致如下：

// detect the steps condition
insert into StepConditionDetected 
select *, current_timestamp as detectedTime select * from pattern[...];

// detect the heartrate condition
insert into HeartrateConditionDetected 
select *, current_timestamp as detectedTime from pattern[...];

// join step and heartrate condition to see if they co-occur in some way
select * from StepConditionDetected.std:unique(macAddress).win:time(15 min) as a,
HeartrateConditionDetected.std:unique(macAddress).win:time(15 min) as b
where a.macAddress = b.macAddress

您可以在where子句中添加这两个条件，并使用“overlap”来实现一些Allen区间代数，即“和a.detecttime.overlaps（b.detectedTime，x，y）”