2017-09-02 62 views
1

我使用Cepheus GE爲我的用例,我啓用它在多租戶模式,並上傳我的config.json文件,但當我開始發送更新到仙王座經紀人的順序爲了將它們轉發給CEP,Cepheus經紀人只收到更新,但不會將它們轉發給Cepheus上限,因爲它無法識別在config.json中設置的服務和服務路徑。當我試圖將我的更新直接發送到Cepheus-CEP時,它接受併成功處理了它們。所以我想知道爲什麼Cepheus經紀人在多租戶模式下啓用時無法識別Fiware服務。錯誤仙王星經紀不轉發更新到仙王座CEP

配置文件服務定義如下

"brokers":[ 
    { 
     "url":"http://XXX.XX.XX.XX:1026", 
     "serviceName": "f", 
     "servicePath": "/f", 
     "authToken": "XXX" 
    } 
] 

這是仙王座經紀人的日誌。

2017-09-02 08:55:32,546 [/O dispatcher 1] WARN c.o.c.b.c.NgsiController - NotifyContext failed for http://localhost:8080/ngsi10/notifyContext$ 
2017-09-02 09:05:33,358 [nio-8081-exec-1] WARN c.o.c.b.c.NgsiController - UpdateContext failed for http://localhost:8082: Connection refused 
java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_72-internal] 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_72-internal] 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:173) ~[httpcore-nio-4.4.1.$ 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:147) ~[httpcore-nio-4.4.1$ 
    at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:350) ~[httpcore-nio-4.4.1.j$ 
    at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:191) ~[httpasync$ 
    at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) ~[httpasyncclient-4.1.jar!$ 
    at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_72-internal] 

java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_72-internal] 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_72-internal] 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:173) ~[httpcore-nio-4.4.1.$ 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:147) ~[httpcore-nio-4.4.1$ 
    at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:350) ~[httpcore-nio-4.4.1.j$ 
    at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:191) ~[httpasync$ 
    at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) ~[httpasyncclient-4.1.jar!$ 
    at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_72-internal] 
2017-09-02 09:33:12,316 [pool-2-thread-1] WARN c.o.c.b.c.NgsiController - UpdateContext failed for http://localhost:8082: Connection refused 
java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_72-internal] 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_72-internal] 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:173) [httpcore-nio-4.4.1.j$ 
    at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:147) [httpcore-nio-4.4.1.$ 
    at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:350) ~[httpcore-nio-4.4.1.j$ 
    at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:191) ~[httpasync$ 
    at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) ~[httpasyncclient-4.1.jar!$ 
    at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_72-internal] 

併發送更新的腳本文件如下所示

(curl XXX.XXX.XXX.XXX:8081/v1/updateContext/ -s -S --header 'Content-Type: application/json' --header "Fiware-Service: f" --header "Fiware-ServicePath:/f " --header 'Accept: application/json' -d @- | python -mjson.tool) <<EOF 

{ "contextElements": [ 
    { 
     "type": "Lab", 
     "isPattern": "false", 
     "id": "Lab111", 
     "attributes": [ 
     { 
      "name": "priority", 
      "type": "double", 
      "value": "1" 
     },        
     { 
      "name": "controller", 
      "type": "string", 
      "value": "Controller111" 
     } 
     ] 
    } 
], 
    "updateAction": "UPDATE" 
} 
EOF 

現在請我想知道這個問題可能是什麼?

+0

@Marc你有什麼想法? – ahmad

回答

0

到目前爲止,Fiware-Cepheus代理不支持多租戶請求(使用Fiware-ServiceFiware-ServicePath標頭),只有CEP可以處理多租戶。更一般地說,與像Orion這樣的全面經紀人相比,經紀人的功能非常少。

如果你需要一個多租戶代理,請使用獵戶座上下文經紀人:https://fiware-orion.readthedocs.io/en/master/user/multitenancy/index.html

+0

我嘗試使用Orion上下文代理與CEP的多租戶代理,但Orion的任何變化沒有達到CEP如何連接CEP與Orion的正確方式 – ahmad

+0

當我訂閱獵戶座時,我得到這個錯誤在*** cepheus不支持請求方法'POST'*** – ahmad