# 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. import uuid from common.proto.kpi_manager_pb2 import KpiId from common.proto.analytics_frontend_pb2 import ( AnalyzerOperationMode, AnalyzerId, Analyzer, AnalyzerFilter ) def create_analyzer_id(): _create_analyzer_id = AnalyzerId() _create_analyzer_id.analyzer_id.uuid = str(uuid.uuid4()) return _create_analyzer_id def create_analyzer(): _create_analyzer = Analyzer() _create_analyzer.algorithm_name = "some_algo_name" _kpi_id = KpiId() _kpi_id.kpi_id.uuid = str(uuid.uuid4()) # input IDs to analyze _create_analyzer.input_kpi_ids.append(_kpi_id) _kpi_id.kpi_id.uuid = str(uuid.uuid4()) # output IDs after analysis _create_analyzer.output_kpi_ids.append(_kpi_id) _create_analyzer.operation_mode = AnalyzerOperationMode.ANALYZEROPERATIONMODE_STREAMING return _create_analyzer def create_analyzer_filter(): _create_analyzer_filter = AnalyzerFilter() _analyzer_id_obj = AnalyzerId() _analyzer_id_obj.analyzer_id.uuid = str(uuid.uuid4()) _create_analyzer_filter.analyzer_id.append(_analyzer_id_obj) _create_analyzer_filter.algorithm_names.append('Algorithum1') _input_kpi_id_obj = KpiId() _input_kpi_id_obj.kpi_id.uuid = str(uuid.uuid4()) _create_analyzer_filter.input_kpi_ids.append(_input_kpi_id_obj) _output_kpi_id_obj = KpiId() _output_kpi_id_obj.kpi_id.uuid = str(uuid.uuid4()) _create_analyzer_filter.output_kpi_ids.append(_output_kpi_id_obj) return _create_analyzer_filter