[ https://jira.fiware.org/browse/HELP-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fernando Lopez reassigned HELP-8918:
------------------------------------
Assignee: Backlog Manager
> [fiware-stackoverflow] CEP 5.4.3, not triggering basic condition
> ----------------------------------------------------------------
>
> Key: HELP-8918
> URL: https://jira.fiware.org/browse/HELP-8918
> Project: Help-Desk
> Issue Type: Monitor
> Components: FIWARE-TECH-HELP
> Reporter: Backlog Manager
> Assignee: Backlog Manager
> Labels: cep, fiware, fiware-cep
>
> Created question in FIWARE Q/A platform on 23-02-2017 at 12:02
> {color: red}Please, ANSWER this question AT{color} https://stackoverflow.com/questions/42413994/cep-5-4-3-not-triggering-basic-condition
> +Question:+
> CEP 5.4.3, not triggering basic condition
> +Description:+
> using CEP i'm trying to make a basic example of communication between Proton and Orion.
> I simply want Proton to receive a notification of temperature from Orion and send back a payload changing one boolean attribute if the temperature value is superior or equal to 20.
> Here is the definition i'm using.
> {
> "epn":
> {
> "events":
> [
> {
> "name": "TemperatureContextUpdate",
> "attributes":
> [
> {
> "dimension": 0,
> "description": "The certainty that this event happen (value between 0 to 1)",
> "name": "Certainty",
> "defaultValue": "1",
> "type": "Double"
> },
> {
> "dimension": 0,
> "description": "No value means it equals the event detection time, other option is to use one of the defined distribution functions with parameters",
> "name": "OccurrenceTime",
> "type": "Date"
> },
> {
> "dimension": 0,
> "name": "ExpirationTime",
> "type": "Date"
> },
> {
> "dimension": 0,
> "description": "The cost of this event occurrence. Negative if this is an opportunity",
> "name": "Cost",
> "type": "Double"
> },
> {
> "dimension": 0,
> "description": "Used in case the this event occur within an interval",
> "name": "Duration",
> "defaultValue": "0",
> "type": "Double"
> },
> {
> "dimension": "0",
> "name": "entityId",
> "type": "String"
> },
> {
> "dimension": "0",
> "name": "entityType",
> "type": "String"
> },
> {
> "dimension": "0",
> "name": "temperature",
> "type": "Integer"
> },
> {
> "dimension": "0",
> "name": "chaud",
> "type": "Boolean"
> }
> ],
> "createdDate": "Wed Feb 22 2017"
> },
> {
> "name": "Out_TemperatureContextUpdate",
> "attributes":
> [
> {
> "dimension": 0,
> "description": "The certainty that this event happen (value between 0 to 1)",
> "name": "Certainty",
> "defaultValue": "1",
> "type": "Double"
> },
> {
> "dimension": 0,
> "description": "No value means it equals the event detection time, other option is to use one of the defined distribution functions with parameters",
> "name": "OccurrenceTime",
> "type": "Date"
> },
> {
> "dimension": 0,
> "name": "ExpirationTime",
> "type": "Date"
> },
> {
> "dimension": 0,
> "description": "The cost of this event occurrence. Negative if this is an opportunity",
> "name": "Cost",
> "type": "Double"
> },
> {
> "dimension": 0,
> "description": "Used in case the this event occur within an interval",
> "name": "Duration",
> "defaultValue": "0",
> "type": "Double"
> },
> {
> "dimension": "0",
> "name": "entityId",
> "type": "String"
> },
> {
> "dimension": "0",
> "name": "entityType",
> "type": "String"
> },
> {
> "dimension": "0",
> "name": "temperature",
> "type": "Integer"
> },
> {
> "dimension": "0",
> "name": "chaud",
> "type": "Boolean"
> }
> ],
> "createdDate": "Wed Feb 22 2017"
> }
> ],
> "name": "TemperatureDemo",
> "consumers":
> [
> {
> "events":
> [
> {
> "name": "Out_TemperatureContextUpdate"
> }
> ],
> "name": "Consumer_Rest",
> "properties":
> [
> {
> "name": "URL",
> "value": "http://172.17.0.3:1026/v2/entities"
> },
> {
> "name": "contentType",
> "value": "application/json"
> },
> {
> "name": "formatter",
> "value": "json_ngsi"
> },
> {
> "name": "delimiter",
> "value": ";"
> },
> {
> "name": "tagDataSeparator",
> "value": "="
> },
> {
> "name": "dateFormat",
> "value": "dd/MM/yyyy-HH:mm:ss"
> }
> ],
> "type": "Rest",
> "createdDate": "Wed Feb 22 2017"
> },
> {
> "events":
> [
> {
> "name": "TemperatureContextUpdate"
> }
> ],
> "name": "Consumer_File",
> "properties":
> [
> {
> "name": "filename",
> "value": "/home/work/Documents/test.txt"
> },
> {
> "name": "formatter",
> "value": "json"
> },
> {
> "name": "delimiter",
> "value": ";"
> },
> {
> "name": "tagDataSeparator",
> "value": "="
> }
> ],
> "type": "File",
> "createdDate": "Wed Feb 22 2017"
> }
> ],
> "epas":
> [
> {
> "inputEvents":
> [
> {
> "instanceSelectionPolicy": "First",
> "alias": "TemperatureContextUpdate",
> "filterExpression": "TemperatureContextUpdate.temperature>=20",
> "name": "TemperatureContextUpdate",
> "consumptionPolicy": "Consume"
> }
> ],
> "derivedEvents":
> [
> {
> "name": "Out_TemperatureContextUpdate",
> "reportParticipants": false,
> "expressions":
> {
> "Cost": "TemperatureContextUpdate.Cost",
> "Certainty": "TemperatureContextUpdate.Certainty",
> "OccurrenceTime": "TemperatureContextUpdate.OccurrenceTime",
> "Duration": "TemperatureContextUpdate.Duration",
> "entityId": "TemperatureContextUpdate.entityId",
> "ExpirationTime": "TemperatureContextUpdate.ExpirationTime",
> "chaud": "true",
> "entityType": "TemperatureContextUpdate.entityType",
> "temperature": "TemperatureContextUpdate.temperature"
> }
> }
> ],
> "evaluationPolicy": "Immediate",
> "name": "EPA_Change",
> "internalSegmentation":
> [
> ],
> "context": "always",
> "epaType": "Basic",
> "cardinalityPolicy": "Single",
> "localPlacement": true,
> "createdDate": "Wed Feb 22 2017",
> "computedVariables":
> [
> ]
> }
> ],
> "optimization":
> {
> },
> "contexts":
> {
> "temporal":
> [
> {
> "terminators":
> [
> ],
> "neverEnding": true,
> "atStartup": true,
> "name": "always",
> "type": "TemporalInterval",
> "createdDate": "Wed Feb 22 2017",
> "initiators":
> [
> ]
> }
> ],
> "segmentation":
> [
> ],
> "composite":
> [
> ]
> },
> "producers":
> [
> ]
> }
> }
> I try to create a file while first update is receive but this file is always empty, btw it is correctly create in my directory and change everytime I change definition. The rest payload is never send like the condition is never triggered.
> The payload I send :
> {
> "subscriptionId": "51c04a21d714fb3b37d7d5a7",
> "data":
> [ {
> "id": "temp1",
> "type": "Temperature",
> "temperature": {
> "type":"integer",
> "value": 28,
> "metadata":{}
> },
> "chaud": {
> "type":"boolean",
> "value": false,
> "metadata":{}
> },
> "Certainty": {
> "value": "1",
> "type": "Float"
> },
> "Cost": {
> "value": "0",
> "type": "Float"
> },
> "Name": {
> "value": "",
> "type": "String"
> },
> "EventSource": {
> "value": "",
> "type": "String"
> },
> "Duration": {
> "value": "0",
> "type": "Float"
> }
> }
> ]
> }
> The log catalina.out :
> INFOS: started event message body reader
> févr. 23, 2017 11:23:35 AM com.ibm.hrl.proton.webapp.providers.EventJSONNgsiMessageReader parseVTwoFormat
> INFOS: Event: TemperatureContextUpdate
> févr. 23, 2017 11:23:35 AM com.ibm.hrl.proton.webapp.providers.EventJSONNgsiMessageReader readFrom
> INFOS: finished event message body reader
> févr. 23, 2017 11:23:35 AM com.ibm.hrl.proton.webapp.providers.EventJSONNgsiMessageReader readFrom
> INFOS: EventJSONNgsiMessageReader: read event TemperatureContextUpdate; entityId=temp1; EventId=ba868559-7589-4720-ab75-658b920a3f14; chaud=false; entityType=Temperature; Chronon=null; temperature=28; DetectionTime=1487845415319; Name=; Certainty=1; Cost=0; EventSource=; OccurrenceTime=null; Duration=0; Annotation=; ExpirationTime=null; from broker...
> févr. 23, 2017 11:23:35 AM com.ibm.hrl.proton.webapp.resources.EventResource submitNewEvent
> INFOS: starting submitNewEvent
> févr. 23, 2017 11:23:35 AM com.ibm.hrl.proton.webapp.resources.EventResource submitNewEvent
> INFOS: events sent to proton runtime...
> So any idea where is my problem ?
> Thanks.
--
This message was sent by Atlassian JIRA
(v6.4.1#64016)
You can get more information about our cookies and privacy policies clicking on the following links: Privacy policy Cookies policy