Skip to end of metadata
Go to start of metadata

You are viewing an old version of this content. View the current version.

Compare with Current View Version History

« Previous Version 7 Next »

Library

Precondition

  • Server flavor : 8 vCPU / 30GB RAM / 100GB HDD
  • Server OS : Ubuntu 16.04

Planned

  • Heat template DONE
  • Heat template commit to gerrit repo DONE
  • HV-VES XNF simulator integration to ONAP procedure DONE

HV-VES simulator standalone mode installation

  • Verify that all docker containers are up :
root@hv-ves-sim:~# docker ps -a
CONTAINER ID        IMAGE                                                       COMMAND                  CREATED             STATUS                    PORTS                                                                            NAMES
5a4c5011bfeb        nexus3.onap.org:10003/onap/ves-hv-collector-xnf-simulator   "./run-java.sh run..."   27 seconds ago      Up 27 seconds             0.0.0.0:6062->6062/tcp                                                           hv-ves_sim_xnf-simulator_1
ad910797eb72        nexus3.onap.org:10003/onap/ves-hv-collector:latest          "./run-java.sh run..."   28 seconds ago      Up 27 seconds (healthy)   0.0.0.0:6060-6061->6060-6061/tcp                                                 hv-ves_sim_ves-hv-collector_1
db196f77fd8e        wurstmeister/kafka                                          "start-kafka.sh"         28 seconds ago      Up 28 seconds             0.0.0.0:9092->9092/tcp                                                           hv-ves_sim_kafka_1
e8713cceb027        progrium/consul                                             "/bin/start -serve..."   30 seconds ago      Up 28 seconds             53/tcp, 53/udp, 8300-8302/tcp, 8400/tcp, 8301-8302/udp, 0.0.0.0:8500->8500/tcp   hv-ves_sim_consul_1
5440e045d0a3        wurstmeister/zookeeper                                      "/bin/sh -c '/usr/..."   30 seconds ago      Up 30 seconds             22/tcp, 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp                               hv-ves_sim_zookeeper_1
root@hv-ves-sim:~#
  • Verify HV-VES configuration from HV-VES docker container :
root@hv-ves-sim:~# docker exec -ti ad910797eb72 bash
root@ad910797eb72:/opt/ves-hv-collector# curl http://consul:8500/v1/kv/veshv-config
[{"CreateIndex":5,"ModifyIndex":5,"LockIndex":0,"Key":"veshv-config","Flags":0,"Value":"eyJrYWZrYUJvb3RzdHJhcFNlcnZlcnMiOiAia2Fma2E6OTA5MiIsInJvdXRpbmciOlt7ImZyb21Eb21haW4iOjExLCJ0b1RvcGljIjoidmVzX2h2UmFuTWVhcyJ9XX0="}]

HV-VES simulator standalone mode usage

  • Start HV-VES container log :
root@hv-ves-sim:~# docker logs --tail 0 -f ad910797eb7
  • Start Kafka consumer log :
root@hv-ves-sim:~# docker exec -ti db196f77fd8e sh
/ # kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ves_hvRanMeas
  • Send message using simulator.sh script :
root@hv-ves-sim:~# hv-ves_sim/simulator.sh send hv-ves_sim/samples/xnf-valid-messages-request.json
{"response":"Request accepted"}
  • Check HV-VES log :
root@hv-ves-sim:~# docker logs --tail 0 -f ad910797eb72
2018-09-05T13:38:32.668Z INFO  [o.o.d.c.v.i.s.NettyTcpServer            ] - Handling connection from /172.18.0.6:51530
2018-09-05T13:38:32.669Z TRACE [o.o.d.c.v.i.w.WireChunkDecoder          ] - Got message with total size of 335 B
2018-09-05T13:38:32.669Z TRACE [o.o.d.c.v.i.w.WireChunkDecoder          ] - Wire payload size: 327 B
2018-09-05T13:38:32.669Z TRACE [o.o.d.c.v.i.w.WireChunkDecoder          ] - Received end-of-transmission message
2018-09-05T13:38:32.670Z INFO  [o.o.d.c.v.i.VesHvCollector              ] - Completing stream because of receiving EOT message
2018-09-05T13:38:32.672Z TRACE [o.o.d.c.v.i.a.k.KafkaSink               ] - Message #10001 has been sent to ves_hvRanMeas:0
2018-09-05T13:38:32.672Z INFO  [o.o.d.c.v.i.s.NettyTcpServer            ] - Connection from /172.18.0.6:51530 has been closed
  • Check Kafka consumer log :
root@hv-ves-sim:~# docker exec -ti db196f77fd8e sh
/ # kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ves_hvRanMeas

?
sample-version
                *sample-version2sample-version:sample-version@???9H???9Rsample-nf-naming-codeZsample-nfc-naming-codebsample-reporting-entity-idjsample-reporting-entity-namersample-source-idzsample-source-namec
a
sample/uri8873???
?    ???????????????????????    ?????/???????a???????

HV-VES simulator integration to ONAP

root@rancher:~# kubectl -n onap get pods | grep hv-ves
dep-dcae-hv-ves-collector-6ddbb546c8-v5gv4      2/2       Running            0          1d
root@rancher:~#
  • Check if xNF simulator is up :
root@hv-ves-sim:~/hv-ves_sim# docker ps -a
CONTAINER ID        IMAGE                                                                                              COMMAND                  CREATED             STATUS              PORTS                    NAMES
eb946d45cc01        nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.hv-ves.hv-collector-xnf-simulator:latest   "./run-java.sh run..."   24 hours ago        Up 24 hours         0.0.0.0:6062->6062/tcp   brave_bartik
root@hv-ves-sim:~/hv-ves_sim#
  • Forward Kafka pod port to node one :
root@rancher:~# kubectl -n onap port-forward dev-message-router-kafka-7d75bf94bc-77jbf 9092:9092
Forwarding from 127.0.0.1:9092 -> 9092
  • Forward HV-VES simulator 9092 port to the node from previous step :
root@hv-ves-sim:~# ssh -L 9092:localhost:9092 10.183.34.151
  • Send event from xNF simulator :
root@hv-ves-sim:~/hv-ves_sim# ./simulator.sh send ./samples/single_xnf-simulator-smaller-valid-request.json
6447df9c-b044-47bb-a1c2-77b6d21b9c9d
root@hv-ves-sim:~/hv-ves_sim#
  • Check HV-VES log :
root@rancher:~# kubectl -n onap logs dep-dcae-hv-ves-collector-6ddbb546c8-v5gv4 dcae-hv-ves-collector -f --tail=4
p.dcae.collectors.veshv.impl.socket.NettyTcpServer | 2018-09-27T10:00:39.020Z | INFO  | Handling connection from /10.42.0.1:56454 |  | reactor-tcp-server-epoll-14
p.dcae.collectors.veshv.impl.socket.NettyTcpServer | 2018-09-27T10:01:39.028Z | INFO  | Idle timeout of 60 s reached. Closing connection from /10.42.0.1:56454... |  | reactor-tcp-server-epoll-14
p.dcae.collectors.veshv.impl.socket.NettyTcpServer | 2018-09-27T10:01:39.029Z | INFO  | Connection from /10.42.0.1:56454 has been closed |  | reactor-tcp-server-epoll-14
p.dcae.collectors.veshv.impl.socket.NettyTcpServer | 2018-09-27T10:01:39.029Z | DEBUG | Channel (/10.42.0.1:56454) closed successfully. |  | reactor-tcp-server-epoll-14
  • Check Kafka topic content :
root@hv-ves-sim:~/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@9H9Rsample-nf-naming-codeZsample-nfc-naming-codejz+)?rsample-reporting-entity-namez
                                                                                  ?{?sample-source-nameanother-versiond
root@hv-ves-sim:~/hv-ves_sim#
  • Decode message from Kafka topic :
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#
  • No labels