Table of Contents

...

No Format

root@hv-ves-sim:~/hv-ves_sim# kafkacat -C -b localhost:9092 -t HV_VES_MEASUREMENTSPERF3GPP -D "" -o -1 -c 1

?
sample-versionHVMEASversionperf3gpp *sample-event-id2sample
perf3GPP222sample-event-name:sample-event-type@????H?9H???9RsampleRsample-nf-naming-codeZsample-nfc-naming-codej??????z?+?)???????rsample-codebsample-nf-vendor-namejsample-reporting-entity-idrsample-reporting-entity-namez-namezsample-source-id?sample-xnf-name?    UTC+02:00?7.0.2test test test
root@hv-ves-sim:~/hv-ves_sim#

Decode message from Kafka topic :

No Format

root@hv-ves-sim:~/hv-ves_sim/proto# kafkacat -C -b localhost:9092 -t HV_VES_PERF3GPP -D "" -o -1 -c 1 | protoc --decode_raw --proto_path=/root/hv-ves_sim/proto/
1 {
  1: "sample-version"
  2: "perf3gpp"
  3: 1
  4: 1
  5: "perf3GPP22"
  6: "sample-event-name"
  7: "sample-event-type"
  8: 1539263857
  9: 1539263857
  10: "sample-nf-naming-code"
  11: "sample-nfc-naming-code"
  12: "sample-nf-vendor-name"
  13: "sample-reporting-entity-id"
    ???????{?sample-source-name?another-versiond
root@hv-ves-sim:~/hv-ves_sim#

Decode message from Kafka topic :

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\00014: "sample-reporting-entity-name"
  15: "sample-source-id"
  16: "sample-xnf-name"
  17: "UTC+02:00"
  18: "7.0.2"
}
2: "test test test"
root@hv-ves-sim:~/hv-ves_sim# sim/proto#

HV-VES message simulation from shell

...

No Format

root@hv-ves-sim:~/hv-ves_sim/proto# cat hvves_event 
commonEventHeader: {
        version: "sample-version"
        eventName: "sample-event-name"
        domain: "HVMEAS"perf3gpp"
        eventId: "perf3GPP22"
        sequenceeventType: 1"sample-event-type"
        prioritynfcNamingCode: 1"sample-nfc-naming-code"
        eventIdnfNamingCode: "sample-eventnf-naming-idcode"
        eventNamenfVendorName: "sample-nf-eventvendor-name"
        eventTypesourceId: "sample-eventsource-typeid"
        startEpochMicrosecsourceName: 120034455"sample-xnf-name"
        lastEpochMicrosecreportingEntityId: 120034455"sample-reporting-entity-id"
        nfNamingCodereportingEntityName: "sample-nfreporting-namingentity-codename"
        nfcNamingCodepriority: "sample-nfc-naming-code"1
        reportingEntityIdstartEpochMicrosec: "sample-reporting-entity-id"1539263857
        reportingEntityNamelastEpochMicrosec: "sample-reporting-entity-name"1539263857
        sourceIdtimeZoneOffset: "sample-source-idUTC+02:00"
        sourceNamesequence: "sample-source-name"1
        vesEventListenerVersion: "another-version7.0.2"
    }
eventFields: "test test test"

root@hv-ves-sim:~/hv-ves_sim/proto# echo -n "\x`cat hvves_event | protoc -I=/home/maras/rootonap/hv-vesonap_simlabs/proto/ VesEvent.proto --encode=VesEvent | xxd -p -c 1000 | grep -o .. | xargs echo -n | sed 's/ /\\\x/g'`"
\x0a\xffx94\x01x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x08\x70\x06x65\x48x72\x56x66\x4dx33\x45x67\x41x70\x53x70\x18\x01\x20\x01\x2a\x0f\x73\x61\x6dx0a\x70\x6c\x65\x2dx72\x65x66\x76x33\x65x47\x6ex50\x74x50\x2dx32\x69\x64x32\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\xf1\x97x9a\xa9xfd\x9exdd\x39x05\x48\xf1\x97x9a\xa9xfd\x9exdd\x39x05\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\x62\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x76\x65\x6e\x64\x6f\x72\x2d\x6e\x61\x6d\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\x12x0f\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x65\x2d\x78\x6e\x66\x2d\x6e\x61\x6d\x65\x92x8a\x01\x09\x55\x0fx54\x61x43\x6ex2b\x6fx30\x74x32\x68x3a\x65x30\x72x30\x2dx92\x76x01\x65x05\x72x37\x73x2e\x69x30\x6fx2e\x6ex32\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74[maras@dais

Put the above VesEvent message into Wire Frame Protocol structure documented in KotlinDoc 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=HEAD :

No Format

\xffxaa\x01\x00\x00\x00\x00\x00\x01\x00\x00\x01\x12x27\x0a\xffx94\x01x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x08\x06x70\x65\x48x72\x56x66\x4dx33\x45x67\x41x70\x53x70\x18\x01\x20\x01\x2a\x0f\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x69\x64x0a\x70\x65\x72\x66\x33\x47\x50\x50\x32\x32\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\xf1\x97x9a\xa9xfd\x9exdd\x39x05\x48\xf1\x97x9a\xa9xfd\x9exdd\x39x05\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\x62\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x76\x65\x6e\x64\x6f\x72\x2d\x6e\x61\x6d\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\x12x0f\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65x78\x6e\x66\x2d\x6e\x61\x6d\x65\x92x8a\x01\x09\x55\x0fx54\x61x43\x6ex2b\x6fx30\x74x32\x68x3a\x65x30\x72x30\x2dx92\x76x01\x65x05\x72x37\x73x2e\x69x30\x6fx2e\x6ex32\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74

...

No Format

root@hv-ves-sim:~/hv-ves_sim/proto# echo -ne "\xffxaa\x01\x00\x00\x00\x00\x00\x01\x00\x00\x01\x12x27\x0a\xffx94\x01x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x08\x70\x06x65\x48x72\x56x66\x4dx33\x45x67\x41x70\x53x70\x18\x01\x20\x01\x2a\x0f\x73\x61\x6dx0a\x70\x6c\x65\x2dx72\x65x66\x76x33\x65x47\x6ex50\x74\x2dx50\x69x32\x64x32\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\xf1\x97x9a\xa9xfd\x9exdd\x39x05\x48\xf1\x97x9a\xa9xfd\x9exdd\x39x05\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\x62\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x76\x65\x6e\x64\x6f\x72\x2d\x6e\x61\x6d\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\x12x0f\x73\x61\x6d\x70\x6c\x65\x2d\x73x78\x6fx6e\x75\x72\x63\x65\x66\x2d\x6e\x61\x6d\x65\x92x8a\x01\x0f\x61\x6e\x6f\x74\x68\x65\x72\x2d\x76\x65\x72\x73\x69\x6f\x6ex09\x55\x54\x43\x2b\x30\x32\x3a\x30\x30\x92\x01\x05\x37\x2e\x30\x2e\x32\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74" | netcat 10.183.35.200k8s_node_ip 30222

Decode the message from Kafka topic :

No Format

root@hv-ves-sim:~# kafkacat -C -b localhost:9092 -t HV_VES_MEASUREMENTSPERF3GPP -D "" -o -1 -c 1 | protoc --decode_raw --proto_path=/root/hv-ves_sim/proto/
1 {
  1: "sample-version"
  2: "HVMEASperf3gpp"
  3: 1
  4: 1
  5: "sample-event-idperf3GPP22"
  6: "sample-event-name"
  7: "sample-event-type"
  8: 1200344551539263857
  9: 1200344551539263857
  10: "sample-nf-naming-code"
  11: "sample-nfc-naming-code"
  12: "sample-nf-vendor-name"
  13: "sample-reporting-entity-id"
  14: "sample-reporting-entity-name"
  15: "sample-source-id"
  16: "sample-sourcexnf-name"
  17: "UTC+02:00"
  18: "another-version7.0.2"
}
2: "test test test"
root@hv-ves-sim:~#

...

Generate testing PKCS #12 files using https://gerrit.onap.org/r/gitweb?p=dcaegen2/collectors/hv-ves.git;a=blob_plain;f=ssl/gen-certs.sh;hb=HEAD and store in k8s nfs dir /dockerdata-nfs/ssl
Edit HV-VES deployment (kubectl -n onap edit deployment/dep-dcae-hv-ves-collector) by removing VESHV_SSL_DISABLE flagand adding VESHV_TRUST_STORE, VESHV_KEY_STORE, VESHV_TRUST_STORE_PASSWORD, VESHV_KEY_STORE_PASSWORD ones.
Add entry to mount node:/dockerdata-nfs/ssl to containter:/etc/ves-hv :

...

Version	Old Version 15	New Version 16
Changes made by	marekPL	marekPL
Saved on	Oct 05, 2018	Oct 15, 2018

Versions Compared

Key

HV-VES message simulation from shell

Content Comparison

Versions Compared

Key

HV-VES message simulation from shell