Dear Fiware Support Team,
I am having the following issue (also posted here:
https://ask.fiware.org/question/1000/connecting-cepheus-to-orion/):
I want to connect Cepheus to Orion (Orion as a source of events), process
some queries and return new events to Orion (this time as destination).
Like depicted below:
Diagram: https://imgur.com/a/CI43Qis
I have tried to configure Cepheus towards this goal, with the following
example configuration:
{
"host": "http://localhost:8080",
"in": [
{
"type": "PersonDetection",
"id": "PersonDetection",
"providers": [
{
"url": "http://orion:1026",
"serviceName": "==SERVICE_NAME==",
"servicePath": "==SERVICE_PATH=="
}
],
"attributes": [
{
"name": "tagId",
"type": "Integer"
},
{
"name": "sectorId",
"type": "Integer"
},
{
"name": "positionX",
"type": "Float"
},
{
"name": "positionY",
"type": "Float"
},
{
"name": "ts",
"type": "Timestamp"
}
]
}
],
"out": [
{
"id": "CellDetection",
"type": "CellDetection",
"attributes": [
{
"name": "cellId",
"type": "Integer"
},
{
"name": "tagId",
"type": "Integer"
},
{
"name": "ts",
"type": "Timestamp"
}
]
}
],
"brokers": [
{
"url": "http://orion:1026",
"serviceName": "==SERVICE_NAME==",
"servicePath": "==SERVICE_PATH=="
}
],
"statements": [
]
}
With this configuration I want Cepheus to receive "PersonDetection" events
(then run some query) and emit "CellDetection" events.
However when Orion emits "PersonDetection" events, I see no logs in the
Cepheus console. Which probably means that he's not receiving any events,
maybe because he did not subscribe to Orion properly.
The only logs generated by Cepheus are the following:
epheus_1 |
/usr/lib/python2.7/dist-packages/supervisor/options.py:296: UserWarning:
Supervisord is running as root and it is searching for its configuration
file in default locations (including its current working directory); you
probably want to specify a "-c" argument specifying an absolute path to a
configuration file for improved security.cepheus_1 | 'Supervisord is
running as root and it is searching '
cepheus_1 | 2018-06-05 18:19:12,362 CRIT Supervisor running as
root (no user in config file)cepheus_1 | 2018-06-05 18:19:12,362 WARN
Included extra file "/etc/supervisor/conf.d/supervisord.conf" during
parsingcepheus_1 | 2018-06-05 18:19:12,378 INFO RPC interface
'supervisor' initialized
cepheus_1 | 2018-06-05 18:19:12,378 CRIT Server 'unix_http_server'
running without any HTTP authentication checking
cepheus_1 | 2018-06-05 18:19:12,378 INFO supervisord started with
pid 1
cepheus_1 | 2018-06-05 18:19:13,381 INFO spawned: 'broker' with
pid 9
cepheus_1 | 2018-06-05 18:19:13,384 INFO spawned: 'cep' with pid 10
cepheus_1 | 2018-06-05 18:19:14,387 INFO success: broker entered
RUNNING state, process has stayed up for > than 1 seconds (startsecs)
cepheus_1 | 2018-06-05 18:19:14,387 INFO success: cep entered
RUNNING state, process has stayed up for > than 1 seconds (startsecs)
cepheus_1 | 2018-06-05 18:19:17.026 INFO 9 --- [ main]
com.orange.cepheus.broker.Application : Starting Application on
e62b33e4a5c1 with PID 9 (/opt/cepheus/cepheus-broker
.jar started by root in /opt/cepheus)
cepheus_1 | 2018-06-05 18:19:17.162 INFO 10 --- [ main]
com.orange.cepheus.cep.Application : Starting Application on
e62b33e4a5c1 with PID 10 (/opt/cepheus/cepheus-cep.
jar started by root in /opt/cepheus)
cepheus_1 | 2018-06-05 18:19:37.016 INFO 9 --- [ main]
com.orange.cepheus.broker.Application : Started Application in 20.785
seconds (JVM running for 23.597)
cepheus_1 | 2018-06-05 18:19:37.639 INFO 10 --- [ main]
com.orange.cepheus.cep.Application : Started Application in 21.395
seconds (JVM running for 24.211)
cepheus_1 | 2018-06-05 18:20:30.115 INFO 10 --- [nio-8080-exec-1]
c.o.c.cep.controller.AdminController : Update configuration
cepheus_1 | 2018-06-05 18:20:30.116 INFO 10 --- [nio-8080-exec-1]
c.o.cepheus.cep.EsperEventProcessor : Apply configuration
cepheus_1 | 2018-06-05 18:20:30.116 INFO 10 --- [nio-8080-exec-1]
c.o.cepheus.cep.EsperEventProcessor : Add new event type:
EventType{id='PersonDetection', type='PersonDetection',
isPattern=false, attributes=[Attribute{name='sectorId', type='Integer',
metadata=[], jsonpath='null'}, Attribute{name='ts', type='Timestamp',
metadata=[], jsonpath='null'}, Attribute{name='
positionX', type='Float', metadata=[], jsonpath='null'},
Attribute{name='positionY', type='Float', metadata=[], jsonpath='null'},
Attribute{name='tagId', type='Integer', metadata=[], jsonpat
h='null'}]}
cepheus_1 | 2018-06-05 18:20:30.190 INFO 10 --- [nio-8080-exec-1]
c.o.cepheus.cep.EsperEventProcessor : Add new event type:
EventType{id='CellDetection', type='CellDetection', isP
attern=false, attributes=[Attribute{name='ts', type='Timestamp',
metadata=[], jsonpath='null'}, Attribute{name='cellId', type='Integer',
metadata=[], jsonpath='null'}, Attribute{name='tagId'
, type='Integer', metadata=[], jsonpath='null'}]}
cepheus_1 | 2018-06-05 18:20:30.220 INFO 10 --- [nio-8080-exec-1]
c.o.c.cep.persistence.JsonPersistence : Save configuration in
/tmp/cep-default-.json
cepheus_1 | 2018-06-05 18:20:30.233 INFO 10 --- [taskScheduler-1]
c.o.cepheus.cep.SubscriptionManager : Launch of the periodic
subscription task at 2018-06-05T18:20:30.229Z
What am I missing?
Thanks!
PS. *==SERVICE_PATH==* and *==SERVICE_NAME==* are just place-holders for
the real path and name.
Best regards,
Pedro Domingues
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.fiware.org/private/fiware-tech-help/attachments/20180605/24af2101/attachment.html>
You can get more information about our cookies and privacy policies clicking on the following links: Privacy policy Cookies policy