[ https://jira.fiware.org/browse/HELP-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andres Muñoz resolved HELP-14246. --------------------------------- Resolution: Done > [fiware-stackoverflow] I am not able to make Orion communicate with Cygnus? > --------------------------------------------------------------------------- > > Key: HELP-14246 > URL: https://jira.fiware.org/browse/HELP-14246 > Project: Help-Desk > Issue Type: Monitor > Components: FIWARE-TECH-HELP > Reporter: Backlog Manager > Assignee: Andres Muñoz > Labels: ckan, fiware, fiware-cygnus, fiware-orion > > Created question in FIWARE Q/A platform on 05-06-2018 at 12:06 > {color: red}Please, ANSWER this question AT{color} https://stackoverflow.com/questions/50698158/i-am-not-able-to-make-orion-communicate-with-cygnus > +Question:+ > I am not able to make Orion communicate with Cygnus? > +Description:+ > I am trying cygnus subscribe to orion. It is giving success, however, but on updating value to orion there is no notificaton being sent to cygnus. Tell me how can I check notification being received to cygnus? Moreover, Is there any method to check successful connection between orion and cygnus. > Configuration and logs of ORION & CYGNUS are below: > POST METHOD on orion for creating:(VERSION - v1 ) > { > "contextElements": [ > { > "type": "Room", > "isPattern": "false", > "id": "Room1", > "attributes": [ > { > "name": "temperature", > "type": "float", > "value": "39.5" > } > ] > } > ], > "updateAction": "UPDATE" > } > **SUBSCRIBING CYGNUS TO ORION ** is as follows: > { > "entities": [ > { > "type": "Room", > "isPattern": "false", > "id": "Room1" > } > ], > "attributes": [ > "temperature" > ], > "reference": "http://cygnus:5050", > "duration": "P1M", > "notifyConditions": [ > { > "type": "ONCHANGE", > "condValues": [ > "temperature" > ] > } > ], > "throttling": "PT60S" > } > My agent.conf file in Cygnus is this : > # ============================================ > # # OrionCKANSink configuration > # # channel name from where to read notification events > cygnusagent.sinks.ckan-sink.channel = ckan-channel > # > # # sink class, must not be changed > cygnusagent.sinks.ckan-sink.type = com.telefonica.iot.cygnus.sinks.OrionCKANSink > # > # # true if the grouping feature is enabled for this sink, false otherwise > cygnusagent.sinks.ckan-sink.enable_grouping = false > # > # # true if lower case is wanted to forced in all the element names, false otherwise > cygnusagent.sinks.hdfs-sink.enable_lowercase = false > # > # # the CKAN API key to use > cygnusagent.sinks.ckan-sink.api_key = 1ae97e2f-1589-4bdf-8a3f-b3683fc66a5a > # > # # the FQDN/IP address for the CKAN API endpoint > cygnusagent.sinks.ckan-sink.ckan_host = demo.ckan.org > # > # # the port for the CKAN API endpoint > cygnusagent.sinks.ckan-sink.ckan_port = 5000 > # > # # Orion URL used to compose the resource URL with the convenience operation URL to query it > cygnusagent.sinks.ckan-sink.orion_url = http://localhost:1026 > # # how the attributes are stored, either per row either per column (row, column) > cygnusagent.sinks.ckan-sink.attr_persistence = column > # > # # enable SSL for secure Http transportation; 'true' or 'false' > cygnusagent.sinks.ckan-sink.ssl = false > # > # # number of notifications to be included within a processing batch > cygnusagent.sinks.ckan-sink.batch_size = 100 > # > # # timeout for batch accumulation > cygnusagent.sinks.ckan-sink.batch_timeout = 60 > # > # # number of retries upon persistence error > cygnusagent.sinks.ckan-sink.batch_ttl = 10 > my Cygnus logs: CYGNUS VERSION - 1.7 > /5/2018 3:37:07 PMtime=2018-06-05T10:07:07.572Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=startAllComponents | msg=org.apache.flume.node.Application[145] : Starting Channel ckan-channel > 6/5/2018 3:37:07 PMtime=2018-06-05T10:07:07.572Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=startAllComponents | msg=org.apache.flume.node.Application[160] : Waiting for channel: ckan-channel to start. Sleeping for 500 ms > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.139Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=main | msg=com.telefonica.iot.cygnus.nodes.CygnusApplication[324] : Starting a Jetty server listening on 0.0.0.0:8081 (Management Interface) > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.193Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=register | msg=org.apache.flume.instrumentation.MonitoredCounterGroup[119] : Monitored counter group for type: CHANNEL, name: ckan-channel: Successfully registered new MBean. > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.250Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=start | msg=org.apache.flume.instrumentation.MonitoredCounterGroup[95] : Component type: CHANNEL, name: ckan-channel started > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.251Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=startAllComponents | msg=org.apache.flume.node.Application[173] : Starting Sink ckan-sink > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.253Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=startAllComponents | msg=org.apache.flume.node.Application[184] : Starting Source http-source > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.392Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.interceptors.CygnusGroupingRules[53] : Grouping rules read: > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.561Z | lvl=WARN | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.interceptors.CygnusGroupingRules[61] : Grouping rules syntax has errors. Details: null > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.581Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.interceptors.CygnusGroupingRules[53] : Grouping rules read: > 6/5/2018 3:37:08 PMtime=2018-06-05T10:07:08.591Z | lvl=WARN | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.interceptors.CygnusGroupingRules[61] : Grouping rules syntax has errors. Details: null > 6/5/2018 3:37:09 PMtime=2018-06-05T10:07:09.917Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=register | msg=org.apache.flume.instrumentation.MonitoredCounterGroup[119] : Monitored counter group for type: SOURCE, name: http-source: Successfully registered new MBean. > 6/5/2018 3:37:09 PMtime=2018-06-05T10:07:09.917Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=start | msg=org.apache.flume.instrumentation.MonitoredCounterGroup[95] : Component type: SOURCE, name: http-source started > 6/5/2018 3:37:11 PMtime=2018-06-05T10:07:11.828Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.backends.http.HttpClientFactory[81] : Setting max total connections (500) > 6/5/2018 3:37:11 PMtime=2018-06-05T10:07:11.828Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.backends.http.HttpClientFactory[82] : Setting default max connections per route (100) > 6/5/2018 3:37:11 PMtime=2018-06-05T10:07:11.866Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.backends.http.HttpClientFactory[81] : Setting max total connections (500) > 6/5/2018 3:37:11 PMtime=2018-06-05T10:07:11.867Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=<init> | msg=com.telefonica.iot.cygnus.backends.http.HttpClientFactory[82] : Setting default max connections per route (100) > 6/5/2018 3:37:11 PMtime=2018-06-05T10:07:11.868Z | lvl=INFO | corr= | trans= | srv= | subsrv= | comp=cygnus-ngsi | op=start | msg=com.telefonica.iot.cygnus.sinks.NGSISink[354] : [ckan-sink] Startup completed -- 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