66c608cb56
Remove usage of local config object in Vitrage services and tests. Instead, it's been replaced with the global CONF object. The structure of the code becomes more like in other OpenStack projects. Also, this change provides an opportunity to introduce migrations and tests for them. Story: 2004059 Task: 27065 Change-Id: I37544a350adf8ca38a6fc4ff5d0fd96e38a3f922
70 lines
2.5 KiB
Python
70 lines
2.5 KiB
Python
# Copyright 2018 - Vitrage team
|
|
#
|
|
# 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.
|
|
|
|
from oslo_log import log as logging
|
|
|
|
from vitrage.common.constants import EntityCategory
|
|
from vitrage.common.constants import VertexProperties as VProps
|
|
from vitrage.datasources.resource_transformer_base import \
|
|
ResourceTransformerBase
|
|
from vitrage.datasources.sample import SAMPLE_DATASOURCE
|
|
from vitrage.datasources.sample import SampleFields
|
|
from vitrage.datasources import transformer_base
|
|
import vitrage.graph.utils as graph_utils
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
class SampleTransformer(ResourceTransformerBase):
|
|
|
|
def __init__(self, transformers):
|
|
super(SampleTransformer, self).__init__(transformers)
|
|
|
|
def _create_snapshot_entity_vertex(self, entity_event):
|
|
return self._create_vertex(entity_event)
|
|
|
|
def _create_update_entity_vertex(self, entity_event):
|
|
return self._create_vertex(entity_event)
|
|
|
|
def _create_snapshot_neighbors(self, entity_event):
|
|
return self._create_sample_neighbors(entity_event)
|
|
|
|
def _create_update_neighbors(self, entity_event):
|
|
return self._create_sample_neighbors(entity_event)
|
|
|
|
def _create_entity_key(self, entity_event):
|
|
"""the unique key of this entity"""
|
|
entity_id = entity_event[VProps.ID]
|
|
entity_type = entity_event[SampleFields.TYPE]
|
|
key_fields = self._key_values(entity_type, entity_id)
|
|
return transformer_base.build_key(key_fields)
|
|
|
|
@staticmethod
|
|
def get_vitrage_type():
|
|
return SAMPLE_DATASOURCE
|
|
|
|
def _create_vertex(self, entity_event):
|
|
return graph_utils.create_vertex(
|
|
self._create_entity_key(entity_event),
|
|
vitrage_category=EntityCategory.RESOURCE,
|
|
vitrage_type=None, # FIXME
|
|
vitrage_sample_timestamp=None, # FIXME
|
|
entity_id=None, # FIXME
|
|
update_timestamp=None, # FIXME
|
|
entity_state=None, # FIXME
|
|
metadata=None) # FIXME
|
|
|
|
def _create_sample_neighbors(self, entity_event):
|
|
return []
|