2013-03-19 3 views
0

게시물이 길어 보이지만 이는 데이터 (샘플 및 오류) 때문입니다.wso2 이벤트 목록의 CEP 오류

cep 2.1.0에서 buildFailed 샘플을 조롱하는 버켓을 만들려고합니다. (이 샘플은 작동합니다).

나는 내 자신의 스트림과 내 자신의 샘플 데이터를 만들었습니다.

아직 그 사건에 문제가있는 cep의 입력 처리기와 이음새가 있습니다.

지금까지 문제를 발견하지 못했습니다.

스트림 정의 :

{ 
    "name":"eu.ima.event.stream", 
    "version": "1.2.0", 
    "nickName": "poc sample", 
    "description": "poc sample stream", 
    "metaData":[ 
    { 
     "name":"host", 
     "type":"string" 
    } 
    ], 
    "correlationData":[ 
    { 
     "name":"processus", 
     "type":"string" 
    }, 
    { 
     "name":"flux", 
     "type":"string" 
    }, 
    { 
     "name":"reference", 
     "type":"string" 
    } 
    ], 
"payloadData":[ 
     { 
       "name":"timestamp", 
       "type":"string" 
     }, 
     {  "name":"code", 
       "type":"string" 
     }, 
     { 
       "name":"category", 
       "type":"string" 
     }, 
     { 
       "name":"msg", 
       "type":"string" 
     } 
    ] 
} 

이벤트 데이터 :

[ 
{ 
"metaData" : ["192.168.1.2"] , 
"correlationData" : ["PSOR", "Appli2", "Ref-1"] , 
"payloadData" : ["1363700128138496600", "6", "BIZ", "6"] 
} 
, 
{ 
"metaData" : ["192.168.1.2"] , 
"correlationData" : ["PSOR", "Appli2", "Ref-0"] , 
"payloadData" : ["1363700126353394500", "6", "BIZ", "6"] 
} 
, 
{ 
"metaData" : ["192.168.1.2"] , 
"correlationData" : ["PSOR", "Appli2", "Ref-3"] , 
"payloadData" : ["1363700131731702100", "6", "BIZ", "6"] 
} 
, 
{ 
"metaData" : ["192.168.1.2"] , 
"correlationData" : ["PSOR", "Appli2", "Ref-2"] , 
"payloadData" : ["1363700129894597000", "6", "BIZ", "6"] 
} 
, 
{ 
"metaData" : ["192.168.1.2"] , 
"correlationData" : ["PSOR", "Appli2", "Ref-4"] , 
"payloadData" : ["1363700133472801700", "6", "BIZ", "6"] 
} 
] 

나는 streamdef, 아니 오류 및 관리자들을 제외하고 로그를 보내

우리는 여기에 더 많은 피드백을해야 할 수도 있습니다 연결. 나는 곱슬 곱슬 게시물 명령을 사용합니다. 당신이 어떤 힌트를해야합니까,

[2013-03-19 14:58:00,586] ERROR {org.wso2.carbon.databridge.core.internal.queue.QueueWorker} - Error in passing event eventList [ 
Event{ 
    streamId='eu.ima.event.stream:1.2.0', 
    timeStamp=0, 
    metaData=[192.168.1.2], 
    correlationData=[PSOR, Appli2, Ref-1], 
    payloadData=[1363700128138496600, 6, BIZ, 6], 
    arbitraryDataMap=null, 
} 
, 
Event{ 
    streamId='eu.ima.event.stream:1.2.0', 
    timeStamp=0, 
    metaData=[192.168.1.2], 
    correlationData=[PSOR, Appli2, Ref-0], 
    payloadData=[1363700126353394500, 6, BIZ, 6], 
    arbitraryDataMap=null, 
} 
, 
Event{ 
    streamId='eu.ima.event.stream:1.2.0', 
    timeStamp=0, 
    metaData=[192.168.1.2], 
    correlationData=[PSOR, Appli2, Ref-3], 
    payloadData=[1363700131731702100, 6, BIZ, 6], 
    arbitraryDataMap=null, 
} 
, 
Event{ 
    streamId='eu.ima.event.stream:1.2.0', 
    timeStamp=0, 
    metaData=[192.168.1.2], 
    correlationData=[PSOR, Appli2, Ref-2], 
    payloadData=[1363700129894597000, 6, BIZ, 6], 
    arbitraryDataMap=null, 
} 
, 
Event{ 
    streamId='eu.ima.event.stream:1.2.0', 
    timeStamp=0, 
    metaData=[192.168.1.2], 
    correlationData=[PSOR, Appli2, Ref-4], 
    payloadData=[1363700133472801700, 6, BIZ, 6], 
    arbitraryDataMap=null, 
} 
] to subscriber org.wso2.carbon.broker.[email protected]2d7fbbd6 
java.lang.NullPointerException 
     at org.wso2.carbon.cep.core.mapping.input.mapping.TupleInputMapping.getValue(TupleInputMapping.java:126) 
     at org.wso2.carbon.cep.core.mapping.input.mapping.TupleInputMapping.convertToEventTuple(TupleInputMapping.java:97) 
     at org.wso2.carbon.cep.core.mapping.input.mapping.InputMapping.convert(InputMapping.java:42) 
     at org.wso2.carbon.cep.core.listener.TopicEventListener.onEvent(TopicEventListener.java:50) 
     at org.wso2.carbon.cep.core.listener.BrokerEventListener.onEvent(BrokerEventListener.java:58) 
     at org.wso2.carbon.broker.core.internal.brokers.agent.AgentBrokerType$AgentBrokerCallback.receive(AgentBrokerType.java:176) 
     at org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:80) 
     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) 
     at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) 
     at java.util.concurrent.FutureTask.run(FutureTask.java:138) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) 
     at java.lang.Thread.run(Thread.java:662) 

하십시오 사람 : 나는 이벤트를 보낼 때

나는 오류가? 개념 증명 CEP 프로젝트를 계속 유지하려면이 사실이 필요합니다.

안부, 시릴

+0

안녕 모두, 나는이 문제를 foud있다. 잘못 구성된 버킷의 입력 매핑이었습니다. 일부 속성의 이름이 잘못 지정되었습니다. 더 효과적인 추적을 위해 버그/개선 요청을 보내겠다고 생각합니다. 로그에 속성 이름이 표시되면 5 초 안에 해결할 수있었습니다. 안부 시릴 –

답변

0

난 당신이 위의 세부를 통과 ...하지만 버킷 구성 및 완전한 오류없이 잘못되었는지 무슨 말을하기 어렵다 로그 ...하지만 내가 체크 한 한 위에서 정의한 스트림 정의 및 이벤트 ... 문제없이 완벽하게 작동하고 있습니다 ... 버킷을 만들 때 실수를 저 지르지 않았 으면 좋겠다. 여기에서 내가 만든 버킷 xml을 공유하고 있습니다. 참고 : 출력 항목의 전자 메일 주소 변경)

이벤트 json : link [1]

스트림 JSON : 링크 [2]

버킷 XML : 링크 [3]

curl 명령 스트림 : 이벤트에 대한

curl -k --user admin:admin https://localhost:9443/datareceiver/1.0.0/streams/ --data @streamdefn2.json -H "Accept: application/json" -H "Content-type: application/json" -X POST 

컬 명령 :

curl -k --user admin:admin https://localhost:9443/datareceiver/1.0.0/stream/eu.ima.event.stream/1.2.0/ --data @events2.json -H "Accept: application/json" -H "Content-type: application/json" -X POST 

(따르십시오 자세한 내용은 [4] 문서를 참조하십시오.

[1] https://docs.google.com/file/d/0B056dKd2JQGJa0pFaU1BTDlEbFk/edit?usp=sharing 

[2] https://docs.google.com/file/d/0B056dKd2JQGJUFdUN21GRGpzY0k/edit?usp=sharing 

[3] https://docs.google.com/file/d/0B056dKd2JQGJa0pFaU1BTDlEbFk/edit?usp=sharing 

[4] http://docs.wso2.org/wiki/display/CEP210/Build+Analyzer 
이 당신을 도울 것입니다 16,

희망 ... 안부, 모한