首页 > 解决方案 > 如何在drools中实现时间持久性?

问题描述

我是流口水的新手,我想知道是否有办法编写及时表达持久性的规则:

如果(条件为真 X 秒)然后 doSomething()

Rule "Example"
when
  r: Room(Temperature > 100 for 10 minutes )
then
  doSomething()
end

标签: javadroolsrules

解决方案


触发 Drools 规则有两种模式——默认为“云”模式,我们在单个时间点评估工作内存中的所有事实。这是触发规则的最古老和最常见的方式。另一种模式是“流”模式,数据连续播放,Drools 引擎知道时间。

在流模式下,Drools 有一组时间运算符(链接到 Drools 文档),可用于针对随时间发生的事实编写条件。

您可以将时间运算符用于您的用例的一种方法如下:

rule "Detect temperature over 100 for 10 minutes"
when
  $t: Temperature(this >= 100) from entry-point "TemperatureStream"
  not(
    Temperature(
      this != $t, 
      this < 100,
      this after[0s,10m] $t) from entry-point "TemperatureStream")
then
  doSomething()
end

这个简单的规则要求您TemperatureStream通过某种外部机制从入口点 ( ) 发送温度事件。当它检测到温度超过 100 度(实例$t)时,第一个条件触发。

第二个条件是魔法发生的地方。第二个条件只有收到.$t

当您的监控应用程序发送温度事件时,每个超过 100 的事件都会触发第一个条件,然后开始监控流以查看第二个条件是否成立。如果是这样,规则的后果将触发。否则规则匹配将被丢弃。

或者,您可以使用超过 10 分钟的滑动窗口来查看最低温度是否曾降至 100 以下。

rule "Detect temperature over 100 for 10 minutes - sliding window"
when
  not(
    Number(doubleValue < 100) from accumulate(
      Room( $temperature: Temperature ) over window:time(10m),
      min( $temperature )
    )
  )
then
  doSomething()
end

这里,window:time(10m)是一个 10 分钟周期内的滑动窗口。与另一种解决方案不同的是,它会在每个事件进入时对其进行观察,然后尝试检查第二个条件是否匹配,这个解决方案只是查看一段时间内的所有事件。如果整个窗口的最低温度从未低于 100,则右侧触发。

可能还有其他方法可以做到这一点,这只是我临时想到的两种。该文档特别适合 Drools 的这一部分,因此您可能会找到另一种更适合您的用例的方法。


推荐阅读