...
| No Format |
|---|
root@hv-ves-sim:~/hv-ves_sim# kafkacat -C -b localhost:9092 -t HV_VES_MEASUREMENTS -D "" -o -1 -c 1 | protoc --decode_raw --proto_path=/root/hv-ves_sim/proto/
1 {
1: "sample-version"
2: "HVMEAS"
3: 1
4: 1
5: "sample-event-id"
6: "sample-event-name"
7: "sample-event-type"
8: 120034455
9: 120034455
10: "sample-nf-naming-code"
11: "sample-nfc-naming-code"
13: "\261\251\251\225\357\253z\232+\266)\340\371\351\355\212\334\276\211"
14: "sample-reporting-entity-name"
15: "\261\251\251\225\357\254\242\352\334{\350\235"
16: "sample-source-name"
18: "another-version"
}
2: "\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000"
root@hv-ves-sim:~/hv-ves_sim# |
HV-VES message simulation from shell
- Prepare HV-VES VesEvent message in hex dump format :
| No Format |
|---|
root@hv-ves-sim:~/hv-ves_sim/proto# cat hvves_event
commonEventHeader: {
version: "sample-version"
domain: "HVMEAS"
sequence: 1
priority: 1
eventId: "sample-event-id"
eventName: "sample-event-name"
eventType: "sample-event-type"
startEpochMicrosec: 120034455
lastEpochMicrosec: 120034455
nfNamingCode: "sample-nf-naming-code"
nfcNamingCode: "sample-nfc-naming-code"
reportingEntityId: "sample-reporting-entity-id"
reportingEntityName: "sample-reporting-entity-name"
sourceId: "sample-source-id"
sourceName: "sample-source-name"
vesEventListenerVersion: "another-version"
}
eventFields: "test test test"
root@hv-ves-sim:~/hv-ves_sim/proto# echo -n "\x`cat hvves_event | protoc -I=/root/hv-ves_sim/proto/ VesEvent.proto --encode=VesEvent | xxd -p -c 1000 | grep -o .. | xargs echo -n | sed 's/ /\\\x/g'`"
\x0a\xff\x01\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x06\x48\x56\x4d\x45\x41\x53\x18\x01\x20\x01\x2a\x0f\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x69\x64\x32\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x6e\x61\x6d\x65\x3a\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x74\x79\x70\x65\x40\x97\xa9\x9e\x39\x48\x97\xa9\x9e\x39\x52\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x5a\x16\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x63\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x6a\x1a\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x69\x64\x72\x1c\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x6e\x61\x6d\x65\x7a\x10\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x69\x64\x82\x01\x12\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x6e\x61\x6d\x65\x92\x01\x0f\x61\x6e\x6f\x74\x68\x65\x72\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74 |
- Put the above VesEvent message into Wire Frame Protocol structure documented in JavaDoc https://gerrit.onap.org/r/gitweb?p=dcaegen2/collectors/hv-ves.git;a=blob_plain;f=hv-collector-domain/src/main/kotlin/org/onap/dcae/collectors/veshv/domain/wire_frame.kt;hb=refs/heads/master :
| No Format |
|---|
\xff\x01\x00\x00\x00\x00\x01\x00\x00\x01\x12\x0a\xff\x01\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x06\x48\x56\x4d\x45\x41\x53\x18\x01\x20\x01\x2a\x0f\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x69\x64\x32\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x6e\x61\x6d\x65\x3a\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x74\x79\x70\x65\x40\x97\xa9\x9e\x39\x48\x97\xa9\x9e\x39\x52\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x5a\x16\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x63\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x6a\x1a\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x69\x64\x72\x1c\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x6e\x61\x6d\x65\x7a\x10\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x69\x64\x82\x01\x12\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x6e\x61\x6d\x65\x92\x01\x0f\x61\x6e\x6f\x74\x68\x65\x72\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74 |
- Send WFP message to HV-VES :
| No Format |
|---|
root@hv-ves-sim:~/hv-ves_sim/proto# echo -ne "\xff\x01\x00\x00\x00\x00\x01\x00\x00\x01\x12\x0a\xff\x01\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x06\x48\x56\x4d\x45\x41\x53\x18\x01\x20\x01\x2a\x0f\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x69\x64\x32\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x6e\x61\x6d\x65\x3a\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x74\x79\x70\x65\x40\x97\xa9\x9e\x39\x48\x97\xa9\x9e\x39\x52\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x5a\x16\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x63\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x6a\x1a\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x69\x64\x72\x1c\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x6e\x61\x6d\x65\x7a\x10\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x69\x64\x82\x01\x12\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x6e\x61\x6d\x65\x92\x01\x0f\x61\x6e\x6f\x74\x68\x65\x72\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74" | netcat 10.183.35.200 30222 |
- Check the message on Kafka topic :
| No Format |
|---|
root@hv-ves-sim:~# kafkacat -C -b localhost:9092 -t HV_VES_MEASUREMENTS -D "" -o -1 -c 1
sample-versionHVMEAS *sample-event-id2sample-event-name:sample-event-type@9H9Rsample-nf-naming-codeZsample-nfc-naming-codejsample-reporting-entity-idrsample-reporting-entity-namezsample-source-idsample-source-nameanother-versiontest test test |
- Encode the message :
| No Format |
|---|
root@hv-ves-sim:~# kafkacat -C -b localhost:9092 -t HV_VES_MEASUREMENTS -D "" -o -1 -c 1 | protoc --decode_raw --proto_path=/root/hv-ves_sim/proto/
1 {
1: "sample-version"
2: "HVMEAS"
3: 1
4: 1
5: "sample-event-id"
6: "sample-event-name"
7: "sample-event-type"
8: 120034455
9: 120034455
10: "sample-nf-naming-code"
11: "sample-nfc-naming-code"
13: "sample-reporting-entity-id"
14: "sample-reporting-entity-name"
15: "sample-source-id"
16: "sample-source-name"
18: "another-version"
}
2: "test test test"
root@hv-ves-sim:~# |