如何解决Drools Fusion SessionPseudoClock 未按预期工作
在运行规则之前,我试图将 KieSession
日期设置为与对象中的日期变量相同的日期。我使用此配置来创建我的 KieSession
KieSessionConfiguration configuration = KieServices.Factory.get().newKieSessionConfiguration();
configuration.setoption(ClockTypeOption.get("pseudo"));
在运行规则之前,我使用 advanceTime()
将会话日期设置为所需日期。
final SessionPseudoClock clock = kSession.getSessionClock();
clock.advanceTime(object.getDate().getTime() - System.currentTimeMillis(),TimeUnit.MILLISECONDS);
final List<Command<?>> commands = new ArrayList<>();
commands.add(CommandFactory.newInsertElements(objects)
commands.add(CommandFactory.newInsert(object,"object"));
final ExecutionResults results = kSession.execute(CommandFactory.newBatchExecution(commands));
这导致使用滑动窗口的规则失火。假设检查 1 小时内通过的对象,而我在过去一小时内没有任何对象。我前一天只有 3 个对象。这是对象的示例数据集。
objects: [
{
clientId: "id",date: 2021-02-09T12:00:38.249Z,...
}
{
clientId: "id",date: 2021-02-09T13:00:38.249Z,date: 2021-02-09T14:00:38.249Z,...
}
]
我有一个规则,用于检查在 1 小时内是否有 2 个以上的对象具有相同的 clientId
。
$object : Object($clientId : clientId)
List( size > 2 ) from collect ( Object( this before $object,clientId == $clientId ) over window:time(1h))
当我传递具有这些值的对象时。上面的规则返回 true,但我们显然没有任何对象在过去一小时内具有日期。
{ clientId: "id",date: 2021-02-10T14:00:38.249Z,... }
我相信这是由于新配置而被破坏,因为它以前在工作(当我没有尝试更改会话时钟时),但我希望会话日期等于对象日期。任何人都知道这里的问题是什么以及如何解决它?
解决方法
正如 Roddy of the Frozen Peas 所说,您需要在每次插入事件之间操作 SessionPseudoClock
。我会实现一个新的 Command
,扩展 InsertElementsCommand
和 @Override
它是 execute
方法:
@Override
public Collection<FactHandle> execute(Context context) {
KieSession kSession = ((RegistryContext) context).lookup(KieSession.class);
List<FactHandle> handles = new ArrayList<>();
Object workingMemory = StringUtils.isEmpty(super.getEntryPoint()) ?
kSession :
kSession.getEntryPoint(super.getEntryPoint());
SessionPseudoClock clock = kSession.getSessionClock();
super.objects.forEach(event -> {
clock.advanceTime(((YourObject) event).getDate().getTime() - clock.getCurrentTime(),TimeUnit.MILLISECONDS);
handles.add(((EntryPoint) workingMemory).insert(event));
});
...
return handles;
}
而不是:
commands.add(CommandFactory.newInsertElements(objects));
我会:
commands.add(new YourInsertElementsCommand(objects));
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。