<html><body><div style="color:#000; background-color:#fff; font-family:times new roman, new york, times, serif;font-size:10pt"><div><span>Thanks for your response. </span></div><div><span>I was under the assumption that the window time frame begins, the moment first event is inserted into the working memory. Or I am still missing out something here (when you say that the first event is exactly at the beginning of the window)? If I traverse backwards as below, then definitely the 1st event lies outside the window.</span></div><div><span> </span></div><div><span> insert 1st event <br><span> delay 1 minute ^ (4 + 1 = 5)</span><br><span> insert 2nd event </span><br><span> delay 1 minute ^ (3 + 1 = 4)</span><br><span> insert 3rd event </span><br><span> delay 1 minute ^ (2 + 1 = 3)</span><br><span> delay 2 minutes ^ </span><br><span>
fire all rules </span></span></div><div><span><span></span></span> </div><div><span><span>However, if I start from the 1st event, the possibility where 1st event lies out of time frame of 5 mins would be if certain amount of time is consumed while inserting the 1st event. I tried to check it programmatically to see if there is any time lapsed during the insertion of the event by printing the clock's current time using clock.getCurrentTime() method before and after inserting the 1st event, however, could not notice any difference.</span></span></div><div><span><span></span></span> </div><div><span><span>But, if I change the time to be advanced by 1 minutes and 59 seconds (instead of 2 minutes) towards the end after the three events have been inserted, the rule seems to be working fine by considering all the three events for calculating the
average.</span></span></div><div><span><span></span></span> </div><div><span><span>I know I am definitely missing out something here as I can see the difference in the behavior of the rule by merely reducing the total delay in time by 1 second (4 min 59 sec instead of 5 minutes) as stated above. But I am not able to figure that out. </span></span></div><div><span><span></span></span> </div><div><span><span>Could you please provide more insight.</span></span></div><div><span><span></span></span> </div><div><span><span>Thanks!</span></span></div> <div class="qtdSeparateBR"><br><br></div><div class="yahoo_quoted" style="display: block;"> <div style="font-family: times new roman, new york, times, serif; font-size: 10pt;"> <div style="font-family: times new roman, new york, times, serif; font-size: 12pt;"> <div dir="ltr"> <font face="Arial" size="2"> On Wednesday, 4 June 2014 9:01 PM, Wolfgang Laun <wolfgang.laun@gmail.com> wrote:<br>
</font> </div> <br><br> <div>Your code does:<br> insert 1st event<br> delay 1 minute<br> insert 2nd event<br> delay 1 minute<br> insert 3rd event<br> delay 1 minute<br> delay (1 or) 2 minutes<br> fire all rules<br><br>In the second case, 5 minutes have elapsed since the 1st insert. I<br>don't think that this means "that [the 1st insert] falls well within<br>the specified time range" - it is exactly at the beginning of the<br>window, and I'd expect the window to be an interval open at one end -<br>otherwise events smack on the point in time "separating" two intervals<br>would be in both windows.<br><br>-W<br><br><br>On 04/06/2014, Sushant Goyal <<a href="mailto:sushantgoyal25@yahoo.co.in" ymailto="mailto:sushantgoyal25@yahoo.co.in">sushantgoyal25@yahoo.co.in</a>> wrote:<br>> Hi,<br>><br>> I am<br>> trying to understand how Drools can be used to monitor events over a period<br>>
of<br>> time using Sliding Time Windows. I have created a rule to sound an alarm<br>> when<br>> average temperature read from a sensor is above 25 degrees (threshold) over<br>> a<br>> time period of 5 minutes. The rule makes of use of the Stream processing<br>> mode so<br>> that continuous stream of events could be processed.<br>><br>> Below<br>> is how my rule looks like:<br>><br>> //declare any global<br>> variables here<br>> globaljava.lang.StringBuilder alertMessage<br>><br>> // add declaration to<br>> change the Fact into an Event<br>> declareSensorReading<br>> @role(event)<br>> end<br>><br>> /* Alert when average<br>> temperature is above 25<br>> over a time period of 5 minutes */<br>> rule"TemperatureAlarm1"<br>><br>> when<br>> //conditions<br>>
$averageTemp : Number(doubleValue ><br>> 25.00)<br>> fromaccumulate(SensorReading($temp<br>> : temperature)<br>> over<br>> window:time(5m) fromentry-point "Temperature Reading", average($temp))<br>> then<br>> //actions<br>> System.out.println("Fired rule:<br>> "+<br>> kcontext.getRule().getName());<br>> alertMessage.append("Threshold<br>> temperature breached!!"+<br>> "\nTurn on the<br>> Air Conditioner"+<br>>
"\nAverage<br>> temperature over 5 minutes is above 25 ("+ $averageTemp.intValue() + ")\n");<br>><br>> end<br>><br>> And below<br>> is the snapshot of the fact (SensorReading) which is inserted as an event in<br>> the working memory:<br>><br>> publicclassSensorReading {<br>><br>> privatedoubletemperature;<br>><br>> publicSensorReading(){}<br>><br>> publicSensorReading(doubletemp){<br>> this.temperature= temp;<br>> }<br>><br>> // getters and setters<br>> }<br>><br>><br>> In<br>> order to test the rule, I am using Pseudo Clock with Stream processing<br>> turned<br>> on. I am inserting three SensorReading objects in the working memory with<br>> temperature<br>> values as (24, 26, 28)
after every minute, so that the average of the<br>> temperatures is above threshold and the rule is invoked. After the objects<br>> are<br>> inserted in the working memory, I am deliberately advancing the Pseudo clock<br>> by<br>> another 1 minute, so that the total time elapsed is 4 minutes. The rule<br>> works<br>> as expected with the above test setup and prints the average value as 26 on<br>> the<br>> console.<br>><br>> However,<br>> if I advance the clock by 2 minutes instead of 1 minute after three sensor<br>> reading objects have been inserted in the working memory (after every 1<br>> minute<br>> interval), the rule gets invoked but the average value gets changed to 27<br>> (26 +<br>> 28 / 2 == 27). Looks like the first temperature reading is getting ignored<br>> by<br>> the rule despite the fact that it falls well within the specified time range<br>> of<br>> 5 minutes. Below is the
snapshot of my test class:<br>><br>> publicclassTemperatureAlarmTest<br>> {<br>><br>> staticKnowledgeBase kbase;<br>> staticStatefulKnowledgeSession ksession;<br>> staticKnowledgeRuntimeLogger logger;<br>> staticSessionPseudoClock clock;<br>><br>> @BeforeClass<br>> publicstaticvoidsetupKsession() {<br>> try{<br>> // load up the<br>> knowledge base<br>> kbase= readKnowledgeBase();<br>> ksession= readKnowldedeSession(kbase);<br>>
clock= ksession.getSessionClock();<br>><br>> logger=<br>> KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, "log/Errors",<br>> 500);<br>><br>> } catch(Throwable t) {<br>> t.printStackTrace();<br>> }<br>> }<br>><br>> /**<br>> *<br>> Create a new Stateful knowledge Session with a pseudo clock from the<br>> *<br>> knowledge base<br>> *<br>> * @paramkbase<br>> * @return<br>> *
@throwsException<br>> */<br>> privatestaticStatefulKnowledgeSession readKnowldedeSession(<br>> KnowledgeBase kbase) throwsException {<br>><br>> // Knowledge Session Configuration<br>> KnowledgeSessionConfiguration<br>> config = KnowledgeBaseFactory.newKnowledgeSessionConfiguration();<br>> config.setOption(ClockTypeOption.get("pseudo"));<br>> returnkbase.newStatefulKnowledgeSession(config, null);<br>><br>> }<br>><br>> @AfterClass<br>> publicstaticvoidcloseKsession() {<br>>
try{<br>> // load up the<br>> knowledge base<br>> logger.close();<br>> ksession.dispose();<br>><br>> } catch(Throwable t) {<br>> t.printStackTrace();<br>> }<br>> }<br>><br>> @Test<br>> publicvoidTemperatureAlarm1_Test() {<br>><br>> // Create Temperature list<br>> ArrayList<SensorReading><br>> tempMetrics =
newArrayList<SensorReading>();<br>> doubletemp = 24.00;<br>><br>> while(tempMetrics.size()<br>> < 3) {<br>> tempMetrics.add(newSensorReading(temp));<br>> temp += 2;<br>> }<br>> System.out.println("Size of<br>> tempMetrics List: "+tempMetrics.size()+"\n");<br>> System.out.println("First Temp<br>> reading: "+tempMetrics.get(0).getTemperature());<br>> System.out.println("Second Temp<br>> reading: "+tempMetrics.get(1).getTemperature());<br>>
System.out.println("Third Temp<br>> reading: "+tempMetrics.get(2).getTemperature()+"\n");<br>><br>> // Separate stream for inserts<br>> WorkingMemoryEntryPoint<br>> temperatureStream = ksession.getWorkingMemoryEntryPoint( "Temperature<br>> Reading");<br>><br>> // Create fact handle list<br>> ArrayList<FactHandle><br>> factHandleList = newArrayList<FactHandle>();<br>><br>> // Insert objects into working<br>> memory while advancing the clock<br>> for(inti = 0; i <<br>> tempMetrics.size(); i++) {<br>><br>>
factHandleList.add(temperatureStream.insert(tempMetrics.get(i)));<br>> clock.advanceTime(1,<br>> TimeUnit.MINUTES);<br>> System.out.println("Time advances<br>> by 1 minute");<br>> }<br>> System.out.println("Fact Count<br>> is: "+temperatureStream.getFactCount());<br>> System.out.println("Fact Entry<br>> Point is: "+temperatureStream.getEntryPointId());<br>> System.out.println("Size of<br>> FactHandleList: "+factHandleList.size()+"\n");<br>><br>> clock.advanceTime(1,<br>> TimeUnit.MINUTES);
//change in<br>> advanced time alters the rule behavior<br>><br>> StringBuilder stringBuilder = newStringBuilder();<br>> ksession.setGlobal("alertMessage", stringBuilder);<br>> ksession.fireAllRules();<br>><br>> // Remove facts<br>> for(inti = 0; i <<br>> factHandleList.size(); i++) {<br>> temperatureStream.retract(factHandleList.get(i));<br>> }<br>> System.out.println("After<br>> Removing facts");<br>> System.out.println("Fact Count<br>> is:
"+temperatureStream.getFactCount());<br>><br>> String result =<br>> stringBuilder.substring(0, 32);<br>> System.out.println("Alert Message<br>> is: \n"+ stringBuilder.toString());<br>> assertEquals("Alert Message<br>> is: ", "Threshold<br>> temperature breached!!", result);<br>> }<br>><br>> /**<br>> *<br>> Create the knowledge base with stream processing turned on.<br>> *<br>> * @return<br>> * @throwsException<br>> */<br>> privatestaticKnowledgeBase<br>> readKnowledgeBase() throwsException {<br>>
KnowledgeBuilder kbuilder =<br>> KnowledgeBuilderFactory.newKnowledgeBuilder();<br>><br>> kbuilder.add(ResourceFactory.newClassPathResource("TemperatureAlarm1.drl"),ResourceType.DRL);<br>> hasErrors(kbuilder);<br>><br>> // Stream processing turned on<br>> KnowledgeBaseConfiguration conf =<br>> KnowledgeBaseFactory.newKnowledgeBaseConfiguration();<br>> conf.setOption(EventProcessingOption.STREAM);<br>> KnowledgeBase kbase =<br>> KnowledgeBaseFactory.newKnowledgeBase(conf);<br>> hasErrors(kbuilder);<br>>
kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());<br>><br>> returnkbase;<br>> }<br>><br>> /**<br>> *<br>> Report errors if any<br>> *<br>> * @paramkbuilder<br>> * @throwsException<br>> */<br>> privatestaticvoidhasErrors(KnowledgeBuilder kbuilder) throwsException<br>> {<br>> KnowledgeBuilderErrors errors =<br>> kbuilder.getErrors();<br>> if(errors.size() > 0) {<br>> for(KnowledgeBuilderError error : errors) {<br>>
System.err.println(error);<br>> }<br>> thrownewIllegalArgumentException("Could not parse<br>> knowledge.");<br>> }<br>><br>> }<br>><br>> }<br>><br>><br>> Could<br>> anyone please help explain this change in the behavior of the rule?<br>><br>> Regards,<br>> Sushant<br><br><br></div> </div> </div> </div> </div></body></html>