fiware - Proton CEP Absence EPA not triggered -
i unable protoncep create event based on absence rule.
the epa "missingqueuedatarule" supposed create event "missingqueuedata" in case no events of type "queuecontextupdate" (the entityid of event not important) received in past time interval (30 seconds).
there no visible errors in logs.
{ "epn": { "events": [ { "name": "device", "createddate": "thu nov 12 2015", "attributes": [ { "name": "datacount5", "type": "integer", "dimension": 0, "description": "the certainty event happen (value between 0 1)" } ] }, { "name": "queue", "createddate": "thu nov 12 2015", "attributes": [ { "name": "name", "type": "string", "dimension": "0" }, { "name": "volume", "type": "integer", "dimension": "0" } ] }, { "name": "devicecontextupdate", "createddate": "thu nov 12 2015", "attributes": [ { "name": "datacount5m", "type": "integer", "dimension": 0, "description": "the certainty event happen (value between 0 1)" }, { "name": "entityid", "type": "string", "dimension": "0" }, { "name": "entitytype", "type": "string", "dimension": "0" }, { "name": "lastupdate", "type": "date", "dimension": "0" }, { "name": "activationdate", "type": "date", "dimension": "0" }, { "name": "efficiencyratio", "type": "double", "dimension": "0" } ] }, { "name": "queuecontextupdate", "createddate": "thu nov 12 2015", "attributes": [ { "name": "volume", "type": "integer", "dimension": "0" }, { "name": "entityid", "type": "string", "dimension": "0" }, { "name": "entitytype", "type": "string", "dimension": "0" } ] }, { "name": "queuevolumehigh", "createddate": "wed jan 27 2016", "attributes": [ { "name": "certainty", "type": "double", "defaultvalue": "1", "dimension": 0, "description": "the certainty event happen (value between 0 1)" }, { "name": "occurrencetime", "type": "date", "dimension": 0, "description": "no value means equals event detection time, other option use 1 of defined distribution functions parameters" }, { "name": "expirationtime", "type": "date", "dimension": 0 }, { "name": "cost", "type": "double", "dimension": 0, "description": "the cost of event occurrence. negative if opportunity" }, { "name": "duration", "type": "double", "defaultvalue": "0", "dimension": 0, "description": "used in case event occur within interval" }, { "name": "affectedentity", "type": "string", "dimension": "0" }, { "name": "affectedentitytype", "type": "string", "dimension": "0" }, { "name": "eventtype", "type": "string", "dimension": "0" }, { "name": "eventseverity", "type": "string", "dimension": "0" }, { "name": "affectedentityvolume", "type": "integer", "dimension": "0" } ] }, { "name": "missingqueuedata", "createddate": "wed jan 27 2016", "attributes": [ { "name": "certainty", "type": "double", "defaultvalue": "1", "dimension": 0, "description": "the certainty event happen (value between 0 1)" }, { "name": "occurrencetime", "type": "date", "dimension": 0, "description": "no value means equals event detection time, other option use 1 of defined distribution functions parameters" }, { "name": "expirationtime", "type": "date", "dimension": 0 }, { "name": "cost", "type": "double", "dimension": 0, "description": "the cost of event occurrence. negative if opportunity" }, { "name": "duration", "type": "double", "defaultvalue": "0", "dimension": 0, "description": "used in case event occur within interval" }, { "name": "eventseverity", "type": "string", "defaultvalue": "\"warning\"", "dimension": "0" } ] } ], "epas": [ { "name": "criticalqueuevolumerule", "description": "emit queuevolumehigh severity=critical if queue volume > 1000", "createddate": "wed jan 27 2016", "createdby": "pedro", "epatype": "all", "context": "criticalqueuevolumecomb", "inputevents": [ { "name": "queuecontextupdate", "filterexpression": "queuecontextupdate.volume>1000", "consumptionpolicy": "consume", "instanceselectionpolicy": "first" } ], "computedvariables": [], "evaluationpolicy": "immediate", "cardinalitypolicy": "single", "internalsegmentation": [], "derivedevents": [ { "name": "queuevolumehigh", "reportparticipants": false, "expressions": { "occurrencetime": "queuecontextupdate.detectiontime", "duration": "0", "affectedentity": "queuecontextupdate.entityid", "affectedentitytype": "queuecontextupdate.entitytype", "eventtype": "\"queuevolumehigh\"", "eventseverity": "\"critical\"", "affectedentityvolume": "queuecontextupdate.volume" } } ] }, { "name": "missingqueuedatarule", "description": "detect when scripts stop working , sending queue data", "createddate": "wed jan 27 2016", "epatype": "absence", "context": "missingqueuedatawindow", "inputevents": [ { "name": "queuecontextupdate", "alias": "q1", "consumptionpolicy": "consume", "instanceselectionpolicy": "first" } ], "computedvariables": [], "evaluationpolicy": "deferred", "cardinalitypolicy": "single", "internalsegmentation": [], "derivedevents": [ { "name": "missingqueuedata", "reportparticipants": false, "expressions": { "certainty": "1.0", "duration": "0", "eventseverity": "\"warning\"" } } ] } ], "contexts": { "temporal": [ { "name": "always", "createddate": "wed jan 27 2016", "type": "temporalinterval", "atstartup": true, "neverending": true, "initiators": [], "terminators": [] }, { "name": "criticalqueuevolumewindow", "description": "start when queue volume > 1000, ends in 30seconds", "createddate": "wed jan 27 2016", "createdby": "pedro", "type": "temporalinterval", "atstartup": false, "neverending": false, "initiators": [ { "initiatortype": "event", "initiatorpolicy": "ignore", "name": "queuecontextupdate", "condition": "queuecontextupdate.volume>1000" } ], "terminators": [ { "terminatortype": "event", "terminatorpolicy": "first", "terminationtype": "terminate", "name": "queuecontextupdate", "condition": " queuecontextupdate.volume<500" }, { "terminatortype": "relativetime", "terminationtype": "terminate", "relativetime": "300000" } ] }, { "name": "missingqueuedatawindow", "createddate": "wed jan 27 2016", "type": "temporalinterval", "atstartup": false, "neverending": false, "initiators": [ { "initiatortype": "event", "initiatorpolicy": "add", "name": "queuecontextupdate" } ], "terminators": [ { "terminatortype": "relativetime", "terminationtype": "terminate", "relativetime": "10000" } ] } ], "segmentation": [ { "name": "queueid", "description": "treat objects distinct based on entityid", "createddate": "wed jan 27 2016", "createdby": "pedro", "participantevents": [ { "name": "queuecontextupdate", "expression": "queuecontextupdate.entityid" }, { "name": "queuevolumehigh", "expression": "queuevolumehigh.affectedentity" } ] } ], "composite": [ { "name": "criticalqueuevolumecomb", "createddate": "wed jan 27 2016", "temporalcontexts": [ { "name": "criticalqueuevolumewindow" } ], "segmentationcontexts": [ { "name": "queueid" } ] } ] }, "consumers": [ { "name": "devicereport", "createddate": "thu nov 12 2015", "type": "file", "properties": [ { "name": "filename", "value": "/usr/share/tomcat/webapps/sample/sentinelmonitor_devicereport.txt" }, { "name": "formatter", "value": "json" }, { "name": "delimiter", "value": ";" }, { "name": "tagdataseparator", "value": "=" }, { "name": "sendingdelay", "value": "1000" } ], "events": [ { "name": "device" } ] }, { "name": "queuereport", "createddate": "thu nov 12 2015", "type": "file", "properties": [ { "name": "filename", "value": "/usr/share/tomcat/webapps/sample/sentinelmonitor_queuereport.txt" }, { "name": "formatter", "value": "json" }, { "name": "delimiter", "value": ";" }, { "name": "tagdataseparator", "value": "=" }, { "name": "sendingdelay", "value": "1000" } ], "events": [ { "name": "queue" } ] }, { "name": "devicecontextupdatereport", "createddate": "thu nov 12 2015", "type": "file", "properties": [ { "name": "filename", "value": "/usr/share/tomcat/webapps/sample/sentinelmonitor_devicecontextupdatereport.txt" }, { "name": "formatter", "value": "json" }, { "name": "delimiter", "value": ";" }, { "name": "tagdataseparator", "value": "=" }, { "name": "sendingdelay", "value": "1000" } ], "events": [ { "name": "devicecontextupdate" } ] }, { "name": "queuecontextupdatereport", "createddate": "thu nov 12 2015", "type": "file", "properties": [ { "name": "filename", "value": "/usr/share/tomcat/webapps/sample/sentinelmonitor_queuecontextupdatereport.txt" }, { "name": "formatter", "value": "json" }, { "name": "delimiter", "value": ";" }, { "name": "tagdataseparator", "value": "=" }, { "name": "sendingdelay", "value": "1000" } ], "events": [ { "name": "queuecontextupdate" }, { "name": "queuevolumehigh" }, { "name": "missingqueuedata" } ] } ], "producers": [], "name": "sentinelmonitor" } }
the issue initiator of temporal context epa using queuecontextupdate event looking find. since event doesn't arrive, context not initiated... , epa not active @ all...
for testing, suggest change initiator of temporal context at startup , try run again.
later, need decide right definition of temporal context, , right initiator. maybe want set temporal context of sliding time window type?
Comments
Post a Comment