<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=us-ascii">
<meta name="Generator" content="Microsoft Word 14 (filtered medium)">
<style><!--
/* Font Definitions */
@font-face
{font-family:Calibri;
panose-1:2 15 5 2 2 2 4 3 2 4;}
/* Style Definitions */
p.MsoNormal, li.MsoNormal, div.MsoNormal
{margin:0in;
margin-bottom:.0001pt;
font-size:11.0pt;
font-family:"Calibri","sans-serif";}
a:link, span.MsoHyperlink
{mso-style-priority:99;
color:blue;
text-decoration:underline;}
a:visited, span.MsoHyperlinkFollowed
{mso-style-priority:99;
color:purple;
text-decoration:underline;}
p.MsoPlainText, li.MsoPlainText, div.MsoPlainText
{mso-style-priority:99;
mso-style-link:"Plain Text Char";
margin:0in;
margin-bottom:.0001pt;
font-size:11.0pt;
font-family:"Calibri","sans-serif";}
p.MsoListParagraph, li.MsoListParagraph, div.MsoListParagraph
{mso-style-priority:34;
margin-top:0in;
margin-right:0in;
margin-bottom:0in;
margin-left:.5in;
margin-bottom:.0001pt;
font-size:11.0pt;
font-family:"Calibri","sans-serif";}
span.EmailStyle17
{mso-style-type:personal-compose;
font-family:"Calibri","sans-serif";
color:windowtext;}
span.PlainTextChar
{mso-style-name:"Plain Text Char";
mso-style-priority:99;
mso-style-link:"Plain Text";
font-family:"Calibri","sans-serif";}
.MsoChpDefault
{mso-style-type:export-only;
font-family:"Calibri","sans-serif";}
@page WordSection1
{size:8.5in 11.0in;
margin:1.0in 1.0in 1.0in 1.0in;}
div.WordSection1
{page:WordSection1;}
/* List Definitions */
@list l0
{mso-list-id:1248199199;
mso-list-type:hybrid;
mso-list-template-ids:914521072 67698705 67698713 67698715 67698703 67698713 67698715 67698703 67698713 67698715;}
@list l0:level1
{mso-level-text:"%1\)";
mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level2
{mso-level-number-format:alpha-lower;
mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level3
{mso-level-number-format:roman-lower;
mso-level-tab-stop:none;
mso-level-number-position:right;
text-indent:-9.0pt;}
@list l0:level4
{mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level5
{mso-level-number-format:alpha-lower;
mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level6
{mso-level-number-format:roman-lower;
mso-level-tab-stop:none;
mso-level-number-position:right;
text-indent:-9.0pt;}
@list l0:level7
{mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level8
{mso-level-number-format:alpha-lower;
mso-level-tab-stop:none;
mso-level-number-position:left;
text-indent:-.25in;}
@list l0:level9
{mso-level-number-format:roman-lower;
mso-level-tab-stop:none;
mso-level-number-position:right;
text-indent:-9.0pt;}
ol
{margin-bottom:0in;}
ul
{margin-bottom:0in;}
--></style><!--[if gte mso 9]><xml>
<o:shapedefaults v:ext="edit" spidmax="1026" />
</xml><![endif]--><!--[if gte mso 9]><xml>
<o:shapelayout v:ext="edit">
<o:idmap v:ext="edit" data="1" />
</o:shapelayout></xml><![endif]-->
</head>
<body lang="EN-US" link="blue" vlink="purple">
<div class="WordSection1">
<p class="MsoNormal">Hi all,<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">A few weeks ago I posted a question about my use case to the mailing list. The correspondence is attached.<o:p></o:p></p>
<p class="MsoNormal">This is the example of the use case I implemented:<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoPlainText">Port scan event - the basic event is connection log. For each combination
<o:p></o:p></p>
<p class="MsoPlainText">of source_ip and destination_ip, detect a port scan event,<br>
if over 5 seconds there were more than 2 connection logs with <o:p></o:p></p>
<p class="MsoPlainText">different ports .<o:p></o:p></p>
<p class="MsoPlainText">The event will stay open for 10 seconds and an update will be
<o:p></o:p></p>
<p class="MsoPlainText">sent for any new port detected. Every update will contain the count of
<o:p></o:p></p>
<p class="MsoNormal">connection logs combining it and their id (“marker”).<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in"><b>the drl fie:<o:p></o:p></b></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">package test;<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">import correlation.impl.drools.Log<o:p></o:p></p>
<p class="MsoNormal">import correlation.impl.drools.CorrelatedEvent<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">global correlation.server.EventsHandler externalEventsHandler;<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">declare Log<o:p></o:p></p>
<p class="MsoNormal"> @role( event)<o:p></o:p></p>
<p class="MsoNormal">end<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">declare CorrelatedEvent<o:p></o:p></p>
<p class="MsoNormal"> @role( event)<o:p></o:p></p>
<p class="MsoNormal"> @timestamp( getTimestamp().getTime() )<o:p></o:p></p>
<p class="MsoNormal"> @expires( 10s )<o:p></o:p></p>
<p class="MsoNormal"> @duration( getDuration() )<o:p></o:p></p>
<p class="MsoNormal">end<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">// this rule will create a “Port Scan“ event if none exist for this group-by values<o:p></o:p></p>
<p class="MsoNormal">rule "Create Port Scan Event"<o:p></o:p></p>
<p class="MsoNormal">dialect "java" <o:p></o:p></p>
<p class="MsoNormal">no-loop <o:p></o:p></p>
<p class="MsoNormal">when<o:p></o:p></p>
<p class="MsoNormal"> $log : Log() from entry-point "Log stream" //get all the logs in the last 5 seconds<o:p></o:p></p>
<p class="MsoNormal"> accumulate( Log( this after[0s,5s] $log, fieldsMap.get("src") == $log.fieldsMap.get("src") , fieldsMap.get("dst") == $log.fieldsMap.get("dst"), $port : fieldsMap.get("port")) from entry-point "Log stream";<o:p></o:p></p>
<p class="MsoNormal"> $portSet : collectSet($port);<o:p></o:p></p>
<p class="MsoNormal"> $portSet.size > 2 )<o:p></o:p></p>
<p class="MsoNormal"> accumulate( Log( this after[0s,5s] $log, fieldsMap.get("src") == $log.fieldsMap.get("src") , fieldsMap.get("dst") == $log.fieldsMap.get("dst"), $marker : fieldsMap.get("marker")) from entry-point "Log stream";<o:p></o:p></p>
<p class="MsoNormal"> $markerSet : collectSet($marker))<o:p></o:p></p>
<p class="MsoNormal"> not CorrelatedEvent(getName() == "portScan" , fieldsMap.get("src") == $log.fieldsMap.get("src") , fieldsMap.get("dst") == $log.fieldsMap.get("dst"))<o:p></o:p></p>
<p class="MsoNormal">then<o:p></o:p></p>
<p class="MsoNormal"> System.out.println(drools.getRule().getName());<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> CorrelatedEvent $ce = new CorrelatedEvent();<o:p></o:p></p>
<p class="MsoNormal"> $ce.setName("portScan");<o:p></o:p></p>
<p class="MsoNormal"> $ce.setEventsHandler(externalEventsHandler);<o:p></o:p></p>
<p class="MsoNormal"> $ce.setDurationInSec(10);<o:p></o:p></p>
<p class="MsoNormal"> $ce.fieldsMap.put("src", $log.fieldsMap.get("src"));<o:p></o:p></p>
<p class="MsoNormal"> $ce.fieldsMap.put("dst", $log.fieldsMap.get("dst"));<o:p></o:p></p>
<p class="MsoNormal"> $ce.endUpdate($markerSet);<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> insert($ce);<o:p></o:p></p>
<p class="MsoNormal">end<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">rule "Create Port Scan Event - update"<o:p></o:p></p>
<p class="MsoNormal">dialect "java" <o:p></o:p></p>
<p class="MsoNormal">no-loop<o:p></o:p></p>
<p class="MsoNormal">when<o:p></o:p></p>
<p class="MsoNormal"> $ce: CorrelatedEvent(getName() == "portScan")<o:p></o:p></p>
<p class="MsoNormal"> accumulate( Log(fieldsMap.get("src") == $ce.fieldsMap.get("src") , fieldsMap.get("dst") == $ce.fieldsMap.get("dst") , $port : fieldsMap.get("port") , (this meets $ce || this during $ce || this metby $ce)) from entry-point "Log stream";<o:p></o:p></p>
<p class="MsoNormal"> $portSet : collectSet($port);<o:p></o:p></p>
<p class="MsoNormal"> $portSet.size > 0 )<o:p></o:p></p>
<p class="MsoNormal"> accumulate( Log(fieldsMap.get("src") == $ce.fieldsMap.get("src") , fieldsMap.get("dst") == $ce.fieldsMap.get("dst") , $marker : fieldsMap.get("marker") , (this meets $ce || this during $ce || this metby $ce)) from entry-point "Log stream";<o:p></o:p></p>
<p class="MsoNormal"> $markerSet : collectSet($marker))<o:p></o:p></p>
<p class="MsoNormal">then<o:p></o:p></p>
<p class="MsoNormal"> System.out.println(drools.getRule().getName());<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> modify( $ce ) {endUpdate($markerSet)}<o:p></o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in">end<o:p></o:p></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">my questions:<o:p></o:p></p>
<p class="MsoListParagraph" style="text-indent:-.25in;mso-list:l0 level1 lfo1"><![if !supportLists]><span style="mso-list:Ignore">1)<span style="font:7.0pt "Times New Roman"">
</span></span><![endif]><span dir="LTR"></span>If I have only one stream of data , can I omit the use of entry point and insert logs to the session ? Or the use of entry points is mandatory in Drools Fusion?<o:p></o:p></p>
<p class="MsoListParagraph" style="text-indent:-.25in;mso-list:l0 level1 lfo1"><![if !supportLists]><span style="mso-list:Ignore">2)<span style="font:7.0pt "Times New Roman"">
</span></span><![endif]><span dir="LTR"></span> When I tested it with matching data, rule "Create Port Scan Event - update" was never fired. When I replaced “(this meets $ce || this during $ce || this metby $ce)” with “this after $ce.getStartTime() , this before
$ce.getEndTime()” everything worked fine.<br>
Why?<o:p></o:p></p>
<p class="MsoListParagraph" style="text-indent:-.25in;mso-list:l0 level1 lfo1"><![if !supportLists]><span style="mso-list:Ignore">3)<span style="font:7.0pt "Times New Roman"">
</span></span><![endif]><span dir="LTR"></span>I tried to use sliding windows in rule "Create Port Scan Event" and an exception was thrown at runtime. I decided to use “this after[0s,5s] $log” instead. Is it correct?<o:p></o:p></p>
<p class="MsoListParagraph" style="text-indent:-.25in;mso-list:l0 level1 lfo1"><![if !supportLists]><span style="mso-list:Ignore">4)<span style="font:7.0pt "Times New Roman"">
</span></span><![endif]><span dir="LTR"></span>Is my basic Implementation correct?
<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">Thank you all very much.<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in"><b>Log class:<o:p></o:p></b></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">public class Log {<o:p></o:p></p>
<p class="MsoNormal"> public HashMap<String, Object> fieldsMap = new HashMap<>();<o:p></o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in">}<o:p></o:p></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in"><b>CorrelatedEvent class:<o:p></o:p></b></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal">public class CorrelatedEvent<o:p></o:p></p>
<p class="MsoNormal">{<o:p></o:p></p>
<p class="MsoNormal"> public Map<String, Object> fieldsMap;<o:p></o:p></p>
<p class="MsoNormal"> private String name;<o:p></o:p></p>
<p class="MsoNormal"> private Set<String> markersSet;<o:p></o:p></p>
<p class="MsoNormal"> private long logsCount;<o:p></o:p></p>
<p class="MsoNormal"> private Calendar startTime;<o:p></o:p></p>
<p class="MsoNormal"> private Calendar endTime;<o:p></o:p></p>
<p class="MsoNormal"> private int duration;<o:p></o:p></p>
<p class="MsoNormal"> private EventsHandler eventsHandler;<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public CorrelatedEvent()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> startTime = Calendar.getInstance();<o:p></o:p></p>
<p class="MsoNormal"> endTime = Calendar.getInstance();<o:p></o:p></p>
<p class="MsoNormal"> endTime.setTime(startTime.getTime());<o:p></o:p></p>
<p class="MsoNormal"> fieldsMap = new HashMap<>();<o:p></o:p></p>
<p class="MsoNormal"> markersSet = new HashSet<>();<o:p></o:p></p>
<p class="MsoNormal"> logsCount = 0;<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"> <o:p></o:p></p>
<p class="MsoNormal"> public Date getTimestamp()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> return startTime.getTime();<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"> <o:p></o:p></p>
<p class="MsoNormal"> public Date getStartTime()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> return startTime.getTime();<o:p></o:p></p>
<p class="MsoNormal"> } <o:p></o:p></p>
<p class="MsoNormal"> <o:p></o:p></p>
<p class="MsoNormal"> public Date getEndTime()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> return endTime.getTime();<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public void setDurationInSec(int duration)<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> this.duration = duration;<o:p></o:p></p>
<p class="MsoNormal"> endTime.setTime(startTime.getTime());<o:p></o:p></p>
<p class="MsoNormal"> endTime.add(Calendar.SECOND, duration);<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"> <o:p></o:p></p>
<p class="MsoNormal"> public int getDuration()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> return duration;<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public String getName()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> return name;<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public void setName(String name)<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> this.name = name;<o:p></o:p></p>
<p class="MsoNormal"> fieldsMap.put("name", name);<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public void setEventsHandler(EventsHandler eventsHandler)<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> this.eventsHandler = eventsHandler;<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> public void endUpdate(Set<String> markersSet)<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> this.markersSet.addAll(markersSet);<o:p></o:p></p>
<p class="MsoNormal"> if (this.markersSet.size() > logsCount) {<o:p></o:p></p>
<p class="MsoNormal"> logsCount = this.markersSet.size();<o:p></o:p></p>
<p class="MsoNormal"> if (eventsHandler == null)<o:p></o:p></p>
<p class="MsoNormal"> return;<o:p></o:p></p>
<p class="MsoNormal"> Map<String, Object> clonedFieldsMap = getClonedFieldsMap();<o:p></o:p></p>
<p class="MsoNormal"> clonedFieldsMap.put("markers", this.markersSet.toString()); //need a function that converts a set of markers to a "\n" separated list<o:p></o:p></p>
<p class="MsoNormal"> clonedFieldsMap.put("count", logsCount);<o:p></o:p></p>
<p class="MsoNormal"> eventsHandler.handleEvent(clonedFieldsMap);<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> private Map<String, Object> getClonedFieldsMap()<o:p></o:p></p>
<p class="MsoNormal"> {<o:p></o:p></p>
<p class="MsoNormal"> Map<String, Object> clonedFieldsMap = new HashMap<>();<o:p></o:p></p>
<p class="MsoNormal"> clonedFieldsMap.putAll(fieldsMap);<o:p></o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"> return clonedFieldsMap;<o:p></o:p></p>
<p class="MsoNormal"> }<o:p></o:p></p>
<p class="MsoNormal"> <o:p></o:p></p>
<div style="mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt;padding:0in 0in 1.0pt 0in">
<p class="MsoNormal" style="border:none;padding:0in">}<o:p></o:p></p>
</div>
<p class="MsoNormal"><o:p> </o:p></p>
<p class="MsoNormal"><o:p> </o:p></p>
</div>
</body>
</html>