使用siddhi进行时间管理

Question

我需要存储一个白名单2分钟，但我需要执行一个查询(使用我的白名单)，当一个新的流到达。我在下面的代码中使用两个流：

我需要每两分钟更新一次白名单。

define trigger periodicalTriggerStream at every 2 min;

from DSB_TEMPORAL#window.time(2 min)
select wlist:whitelist() as whitel , DSB_licensekey, flg_urldsb
insert into temporal;

我需要这个查询在到达一个新事件时执行。(我使用我的白名单)

from temporal
select findwlist:findwhitelist(DSB_licensekey, flg_urldsb, whitel) as flg_url11
insert into temporal_WL11;

这是可能的吗？

Answer 1

这样行得通吗？

define trigger periodicalTriggerStream at every 2 min;

from periodicalTriggerStream
select wlist:whitelist() as whitel 
insert into whitelStream;

from whitelStream#window.length(1) join newEventStream 
select findwlist:findwhitelist(DSB_licensekey, flg_urldsb, whitel) as flg_url11
insert into temporal_WL11;

基本思想是每隔2分钟计算一次wlist:whitelist()，将结果存储在#window.length(1)中，然后将新事件与事件窗口连接起来。