如何解决如何防止流口水引擎在入口点数据上循环
我正在使用 drools 来对流式交易数据发出警报。 drools 引擎是 STREAM 和 ACTIVE 模式。我还使用入口点 (OM-TRANS) 将数据传输到规则引擎。 我写了一个简单的规则来测试引擎的行为。我得到了一些结果,但我不理解它们,它们不是我所期望的。
这是第一个简单的规则:
rule "My rule"
no-loop true
when
$transaction: TransactionOmDto($msisdn: msisdn) from entry-point "OM-TRANS"
then
System.out.println("------------ an alarm on "+$msisdn+" ----------");
end
这些是我测试后得到的结果:
- 来自 msisdn 的交易msisdn_1:
------------ an alarm on msisdn_1 ----------
- 再次来自 msisdn msisdn_1 的交易:
------------ an alarm on msisdn_1 ----------
- 来自 msisdn 的交易msisdn_2:
------------ an alarm on msisdn_2 ----------
- 再次来自 msisdn msisdn_2 的交易:
------------ an alarm on msisdn_2 ----------
- 来自 msisdn 的交易msisdn_3:
------------ an alarm on msisdn_3 ----------
这是规则的第二个版本:
rule "My rule"
no-loop true
when
$transaction: TransactionOmDto($msisdn: msisdn) from entry-point "OM-TRANS"
$datasTransaction: List() from collect(TransactionOmDto(msisdn == $msisdn) from entry-point "OM-TRANS")
then
System.out.println("------------ an alarm on "+$msisdn+",total Transaction: "+$datasTransaction.size()+" ----------");
end
我得到了以下结果和我期望的结果:
- 来自 msisdn 的交易msisdn_1:
------------ an alarm on msisdn_1,total Transaction: 1 ----------
(这是预期的)
- 再次来自 msisdn msisdn_1 的交易:
------------ an alarm on msisdn_1,total Transaction: 2 ----------
------------ an alarm on msisdn_1,total Transaction: 2 ----------
我期望的是:单行------------ msisdn_1 上的警报,总交易:2 -------- --
- 来自 msisdn 的交易msisdn_2:
------------ an alarm on msisdn_2,total Transaction: 1 ----------
(如预期)
- 再次来自 msisdn msisdn_2 的交易:
------------ an alarm on msisdn_2,total Transaction: 2 ----------
------------ an alarm on msisdn_2,total Transaction: 2 ----------
我期望的是:单行------------ msisdn_2 上的警报,总交易:2 -------- --
- 来自 msisdn 的交易msisdn_3:
------------ an alarm on msisdn_3,total Transaction: 1 ----------
(这是预期的)
- 再次来自 msisdn msisdn_3 的交易:
------------ an alarm on msisdn_3,total Transaction: 2 ----------
------------ an alarm on msisdn_3,total Transaction: 2 ----------
我期望的是:单行------------ msisdn_3 上的警报,总交易:2 -------- --
- 再次来自 msisdn msisdn_3 的交易:
------------ an alarm on msisdn_3,total Transaction: 3 ----------
------------ an alarm on msisdn_3,total Transaction: 3 ----------
我期望的是:单行------------ msisdn_3 上的警报,总交易:3 -------- --
有人可以向我解释为什么我得到这些结果吗? 有可能得到我所期望的吗? 谢谢你。
解决方法
因为您的事件仅在 24 小时内到期,所以较旧的事件确实会参与规则逻辑。
通常这可以通过滑动长度窗口来修复
over window:length(1) from entry-point "OM-TRANS"
完整片段
rule "My rule2"
no-loop true
when
$transaction: TransactionOmDto($msisdn: msisdn) over window:length(1) from entry-point "OM-TRANS"
$datasTransaction: List() from collect(TransactionOmDto(msisdn == $msisdn) from entry-point "OM-TRANS")
then
System.out.println("------------ an alarm on "+$msisdn+",total Transaction: "+$datasTransaction.size()+" ----------");
end
输出
------------ an alarm on msisdn_1,total Transaction: 1 ----------
------------ an alarm on msisdn_1,total Transaction: 2 ----------
------------ an alarm on msisdn_1,total Transaction: 3 ----------
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。