5c34e9c240be4e65db7209406e890ff9da5dc251
1 # Copyright 2018 Whitestack, LLC
2 # *************************************************************
4 # This file is part of OSM Monitoring module
5 # All Rights Reserved to Whitestack, LLC
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: bdiaz@whitestack.com or glavado@whitestack.com
23 from typing
import List
25 from keystoneauth1
import session
26 from keystoneauth1
.identity
import v3
27 from keystoneclient
.v3
import client
as keystone_client
28 from novaclient
import client
as nova_client
29 from novaclient
import v2
as nova_client_v2
31 from osm_mon
.collector
.infra_collectors
.base_vim
import BaseVimInfraCollector
32 from osm_mon
.collector
.metric
import Metric
33 from osm_mon
.core
.auth
import AuthManager
34 from osm_mon
.core
.common_db
import CommonDbClient
35 from osm_mon
.core
.config
import Config
37 log
= logging
.getLogger(__name__
)
40 class OpenstackInfraCollector(BaseVimInfraCollector
):
41 def __init__(self
, config
: Config
, vim_account_id
: str):
42 super().__init
__(config
, vim_account_id
)
43 self
.auth_manager
= AuthManager(config
)
44 self
.keystone
= self
._build
_keystone
_client
(vim_account_id
)
45 self
.nova
= self
._build
_nova
_client
(vim_account_id
)
46 self
.vim_account_id
= vim_account_id
47 self
.common_db
= CommonDbClient(config
)
49 def collect(self
) -> List
[Metric
]:
51 vim_status
= self
.is_vim_ok()
52 vim_status_metric
= Metric({'vim_account_id': self
.vim_account_id
}, 'vim_status', vim_status
)
53 metrics
.append(vim_status_metric
)
54 vnfrs
= self
.common_db
.get_vnfrs(vim_account_id
=self
.vim_account_id
)
56 nsr_id
= vnfr
['nsr-id-ref']
57 vnf_member_index
= vnfr
['member-vnf-index-ref']
58 for vdur
in vnfr
['vdur']:
59 resource_uuid
= vdur
['vim-id']
60 vm
= self
.nova
.servers
.get(resource_uuid
)
61 vm_status
= (1 if vm
.status
== 'ACTIVE' else 0)
63 'vim_account_id': self
.vim_account_id
,
64 'resource_uuid': resource_uuid
,
66 'vnf_member_index': vnf_member_index
,
67 'vdur_name': vdur
['name']
69 vm_status_metric
= Metric(tags
, 'vm_status', vm_status
)
70 metrics
.append(vm_status_metric
)
74 def is_vim_ok(self
) -> bool:
76 self
.keystone
.projects
.list()
79 log
.exception("VIM status is not OK!")
82 def _build_keystone_client(self
, vim_account_id
) -> keystone_client
.Client
:
83 sess
= self
._get
_session
(vim_account_id
)
84 return keystone_client
.Client(session
=sess
)
86 def _build_nova_client(self
, vim_account_id
) -> nova_client_v2
.Client
:
87 sess
= self
._get
_session
(vim_account_id
)
88 return nova_client
.Client("2", session
=sess
)
90 def _get_session(self
, vim_account_id
):
91 creds
= self
.auth_manager
.get_credentials(vim_account_id
)
92 verify_ssl
= self
.auth_manager
.is_verify_ssl(vim_account_id
)
93 auth
= v3
.Password(auth_url
=creds
.url
,
95 password
=creds
.password
,
96 project_name
=creds
.tenant_name
,
97 project_domain_id
='default',
98 user_domain_id
='default')
99 return session
.Session(auth
=auth
, verify
=verify_ssl
)