Commit 1a383d92 authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Merge branch 'feat/191-cttc-implement-telemetry-backend-collector-emulated'... 

Merge branch 'feat/191-cttc-implement-telemetry-backend-collector-emulated' into feat/247-cttc-analytics-module-enhancements
To get the latest info from other branch.
parents 1d16da8d c09c401a

my_deploy.sh

+1 −1
Original line number Diff line number Diff line
@@ -26,7 +26,7 @@ export TFS_COMPONENTS="context device pathcomp service slice nbi webui" 
#export TFS_COMPONENTS="${TFS_COMPONENTS} monitoring"



# Uncomment to activate Monitoring Framework (new)

#export TFS_COMPONENTS="${TFS_COMPONENTS} kpi_manager kpi_value_writer kpi_value_api telemetry analytics automation"

export TFS_COMPONENTS="${TFS_COMPONENTS} kpi_manager kpi_value_writer kpi_value_api telemetry analytics automation"



# Uncomment to activate QoS Profiles

#export TFS_COMPONENTS="${TFS_COMPONENTS} qos_profile"

scripts/run_tests_locally-telemetry-backend.sh

+2 −5
Original line number Diff line number Diff line
@@ -18,15 +18,12 @@ PROJECTDIR=`pwd` 


cd $PROJECTDIR/src

# RCFILE=$PROJECTDIR/coverage/.coveragerc

# coverage run --rcfile=$RCFILE --append -m pytest --log-level=INFO --verbose \

#     kpi_manager/tests/test_unitary.py



# python3 kpi_manager/tests/test_unitary.py

export KFK_SERVER_ADDRESS='127.0.0.1:9092'

CRDB_SQL_ADDRESS=$(kubectl get service cockroachdb-public --namespace crdb -o jsonpath='{.spec.clusterIP}')

export CRDB_URI="cockroachdb://tfs:tfs123@${CRDB_SQL_ADDRESS}:26257/tfs_telemetry?sslmode=require"

RCFILE=$PROJECTDIR/coverage/.coveragerc





python3 -m pytest --log-level=INFO --log-cli-level=debug --verbose \

    telemetry/backend/tests/test_TelemetryBackend.py
 
python3 -m pytest --log-level=debug --log-cli-level=debug --verbose \

    telemetry/backend/tests/test_backend.py

scripts/run_tests_locally-telemetry-emulated.sh

0 → 100755
+29 −0
Original line number Diff line number Diff line 
#!/bin/bash

# Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)

#

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

#      http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.





PROJECTDIR=`pwd`



cd $PROJECTDIR/src

# RCFILE=$PROJECTDIR/coverage/.coveragerc



# export KFK_SERVER_ADDRESS='127.0.0.1:9092'

# CRDB_SQL_ADDRESS=$(kubectl get service cockroachdb-public --namespace crdb -o jsonpath='{.spec.clusterIP}')

# export CRDB_URI="cockroachdb://tfs:tfs123@${CRDB_SQL_ADDRESS}:26257/tfs_telemetry?sslmode=require"

RCFILE=$PROJECTDIR/coverage/.coveragerc





python3 -m pytest --log-level=debug --log-cli-level=info --verbose \

    telemetry/backend/tests/test_emulated.py

src/common/tools/kafka/Variables.py

+4 −4
Original line number Diff line number Diff line
@@ -41,14 +41,14 @@ class KafkaConfig(Enum): 


class KafkaTopic(Enum):

    # TODO: Later to be populated from ENV variable.

    REQUEST            = 'topic_request' 

    RESPONSE           = 'topic_response'

    TELEMETRY_REQUEST  = 'topic_telemetry_request' 

    TELEMETRY_RESPONSE = 'topic_telemetry_response'

    RAW                = 'topic_raw' 

    LABELED            = 'topic_labeled'

    VALUE              = 'topic_value'

    ALARMS             = 'topic_alarms'

    ANALYTICS_REQUEST  = 'topic_request_analytics'

    ANALYTICS_RESPONSE = 'topic_response_analytics'

    ANALYTICS_REQUEST  = 'topic_analytics_request'

    ANALYTICS_RESPONSE = 'topic_analytics_response'



    @staticmethod

    def create_all_topics() -> bool:

src/telemetry/backend/drivers/__init__.py

0 → 100644
+13 −0
Original line number Diff line number Diff line 
# Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)

#

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

#      http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.