1 # Copyright 2017 Intel Research and Development Ireland Limited
2 # *************************************************************
4 # This file is part of OSM Monitoring module
5 # All Rights Reserved to Intel Corporation
7 # Licensed under the Apache License, Version 2.0 (the "License"); you may
8 # not use this file except in compliance with the License. You may obtain
9 # a copy of the License at
11 # http://www.apache.org/licenses/LICENSE-2.0
13 # Unless required by applicable law or agreed to in writing, software
14 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
15 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
16 # License for the specific language governing permissions and limitations
19 # For those usages not covered by the Apache License, Version 2.0 please
20 # contact: helena.mcgough@intel.com or adrian.hoban@intel.com
22 """Global configuration managed by environment variables."""
27 from collections
import namedtuple
29 from osm_mon
.plugins
.OpenStack
.singleton
import Singleton
33 __author__
= "Helena McGough"
35 log
= logging
.getLogger(__name__
)
38 class BadConfigError(Exception):
39 """Configuration exception."""
44 class CfgParam(namedtuple('CfgParam', ['key', 'default', 'data_type'])):
45 """Configuration parameter definition."""
47 def value(self
, data
):
48 """Convert a string to the parameter type."""
50 return self
.data_type(data
)
51 except (ValueError, TypeError):
53 'Invalid value "%s" for configuration parameter "%s"' % (
59 """Configuration object."""
62 CfgParam('BROKER_URI', "localhost:9092", six
.text_type
),
63 CfgParam('MONGO_URI', "mongo:27017", six
.text_type
),
64 CfgParam('DATABASE', "sqlite:///mon_sqlite.db", six
.text_type
),
65 CfgParam('OS_NOTIFIER_URI', "http://localhost:8662", six
.text_type
),
66 CfgParam('OS_DEFAULT_GRANULARITY', "300", six
.text_type
),
67 CfgParam('REQUEST_TIMEOUT', 10, int),
70 _config_dict
= {cfg
.key
: cfg
for cfg
in _configuration
}
71 _config_keys
= _config_dict
.keys()
74 """Set the default values."""
75 for cfg
in self
._configuration
:
76 setattr(self
, cfg
.key
, cfg
.default
)
79 def read_environ(self
):
80 """Check the appropriate environment variables and update defaults."""
81 for key
in self
._config
_keys
:
83 val
= self
._config
_dict
[key
].data_type(os
.environ
[key
])
84 setattr(self
, key
, val
)
85 except KeyError as exc
:
86 log
.debug("Environment variable not present: %s", exc
)