Code Review / demo.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: fb9b7ba) | patch
First working draft of kafka for inference app 36/97836/4
authorRajamohan Raj <rajamohan.raj@intel.com>
Fri, 1 Nov 2019 00:30:30 +0000 (00:30 +0000)
committerMarco Platania <platania@research.att.com>
Thu, 14 Nov 2019 14:10:09 +0000 (14:10 +0000)
commit53c9fab327d1d9a079154b01242cf0930c106989
tree4cc6bc25a290c6ac3e6028122192de1dd9493646tree | snapshot
parentfb9b7baa506e5c92bc243a30364e9f72ecd9c3f1commit | diff
First working draft of kafka for inference app

Created a python based inference app which can query a given metrics for
a given duration from kafka topic.
Consumer runs on separate thread and doesnt interfere with the main app.

Issue-ID: ONAPARC-528
Signed-off-by: Rajamohan Raj <rajamohan.raj@intel.com>
Change-Id: Ic84ea137b134385246bf11dee2ed6d34b593b956
12 files changed:
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/README.md [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/kubernetes-manifests/kafka.inference.deploy.yaml [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/skaffold.yaml [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/Dockerfile [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/__init__.py [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/__init__.py [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/main.py [new file with mode: 0755] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/CustomKafkaProducer.py [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/__init__.py [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/requirements.txt [new file with mode: 0644] blob
vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/utils/utils.py [new file with mode: 0644] blob
Demo applications and templates for ONAP platform instantiation.