From 968892b0727285466c568846796c4d7354032654 Mon Sep 17 00:00:00 2001 From: zhangab Date: Mon, 26 Mar 2018 10:00:22 +0800 Subject: support fcaps Change-Id: Id7ef66b74a6569da3ad73f215f9dca863fea5f7a Issue-ID: MULTICLOUD-201 Signed-off-by: zhangab --- share/newton_base/openoapi/alarm.py | 92 ++++++++++++++++++++++++++++++++ share/newton_base/openoapi/hypervisor.py | 70 ++++++++++++++++++++++++ share/newton_base/openoapi/sample.py | 92 ++++++++++++++++++++++++++++++++ share/newton_base/openoapi/vmlist.py | 74 +++++++++++++++++++++++++ 4 files changed, 328 insertions(+) create mode 100755 share/newton_base/openoapi/alarm.py create mode 100755 share/newton_base/openoapi/hypervisor.py create mode 100755 share/newton_base/openoapi/sample.py create mode 100755 share/newton_base/openoapi/vmlist.py diff --git a/share/newton_base/openoapi/alarm.py b/share/newton_base/openoapi/alarm.py new file mode 100755 index 00000000..3cbcf9ad --- /dev/null +++ b/share/newton_base/openoapi/alarm.py @@ -0,0 +1,92 @@ +# Copyright 2018 CMCC Technologies Co.,Ltd +# +# 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 logging +import threading +import traceback +from keystoneauth1.exceptions import HttpError +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView + +from common.exceptions import VimDriverNewtonException +from newton_base.util import VimDriverUtils + +logger = logging.getLogger(__name__) + +running_threads = {} +running_thread_lock = threading.Lock() + + +class Alarms(APIView): + service = {'service_type': 'metering', + 'interface': 'public'} + keys_mapping = [ + ("project_id", "tenantId"), + ("disk_format", "alarmType"), + ("container_format", "containerFormat") + ] + + def get(self, request, vimid="", tenantid="", alarmid=""): + logger.debug("alarms--get::> %s" % request.data) + try: + # prepare request resource to vim instance + query = VimDriverUtils.get_query_part(request) + content, status_code = self.get_alarms(query, vimid, tenantid, alarmid) + return Response(data=content, status=status_code) + except VimDriverNewtonException as e: + return Response(data={'error': e.content}, status=e.status_code) + except HttpError as e: + logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) + return Response(data=e.response.json(), status=e.http_status) + except Exception as e: + logger.error(traceback.format_exc()) + return Response(data={'error': str(e)}, + status=status.HTTP_500_INTERNAL_SERVER_ERROR) + + def get_alarms(self, query="", vimid="", tenantid="", alarmid=""): + logger.debug("alarms--get_alarms::> %s" % alarmid) + + # prepare request resource to vim instance + req_resouce = "/v2/alarms" + if alarmid: + req_resouce += "/%s" % alarmid + elif query: + req_resouce += "?%s" % query + + vim = VimDriverUtils.get_vim_info(vimid) + vim["domain"] = "Default" + sess = VimDriverUtils.get_session(vim, tenantid) + resp = sess.get(req_resouce, endpoint_filter=self.service) + content = resp.json() + vim_dict = { + "vimName": vim["name"], + "vimId": vim["vimId"], + "tenantId": tenantid, + } + + '''if not alarmid: + # convert the key naming in alarms + for alarm in content["alarms"]: + VimDriverUtils.replace_key_by_mapping(alarm, + self.keys_mapping) + else: + # convert the key naming in the alarm specified by id + #alarm = content.pop("alarm", None) + VimDriverUtils.replace_key_by_mapping(content, + self.keys_mapping) + #content.update(alarm)''' + + return content, resp.status_code + + diff --git a/share/newton_base/openoapi/hypervisor.py b/share/newton_base/openoapi/hypervisor.py new file mode 100755 index 00000000..147fbc44 --- /dev/null +++ b/share/newton_base/openoapi/hypervisor.py @@ -0,0 +1,70 @@ +# Copyright 2018 CMCC Technologies Co.,Ltd +# +# 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 logging +import threading +import traceback +from keystoneauth1.exceptions import HttpError +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView + +from common.exceptions import VimDriverNewtonException +from newton_base.util import VimDriverUtils + +logger = logging.getLogger(__name__) + +running_threads = {} +running_thread_lock = threading.Lock() + +class Hypervisors(APIView): + service = {'service_type': 'compute', + 'interface': 'public'} + keys_mapping = [ + ("project_id", "tenantId"), + ("disk_format", "serverType"), + ("container_format", "containerFormat") + ] + + + def get(self, request, vimid="", tenantid="", hypervisorid=""): + logger.debug("hypervisors--get::> %s" % request.data) + try: + query = VimDriverUtils.get_query_part(request) + content, status_code = self.get_hypervisors(query, vimid, tenantid, hypervisorid) + return Response(data=content, status=status_code) + except VimDriverNewtonException as e: + return Response(data={'error': e.content}, status=e.status_code) + except HttpError as e: + logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) + return Response(data=e.response.json(), status=e.http_status) + except Exception as e: + logger.error(traceback.format_exc()) + return Response(data={'error': str(e)}, + status=status.HTTP_500_INTERNAL_SERVER_ERROR) + + + def get_hypervisors(self, query="", vimid="", tenantid="", hypervisorid=""): + logger.debug("hypervisors--get::> %s" % hypervisorid) + + req_resource = "/os-hypervisors" + + vim = VimDriverUtils.get_vim_info(vimid) + vim["domain"] = "Default" + sess = VimDriverUtils.get_session(vim, tenantid) + resp = sess.get(req_resource, endpoint_filter = self.service) + content = resp.json() + + return content, resp.status_code + diff --git a/share/newton_base/openoapi/sample.py b/share/newton_base/openoapi/sample.py new file mode 100755 index 00000000..81455d0b --- /dev/null +++ b/share/newton_base/openoapi/sample.py @@ -0,0 +1,92 @@ +# Copyright 2018 CMCC Technologies Co.,Ltd +# +# 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 logging +import threading +import traceback +from keystoneauth1.exceptions import HttpError +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView + +from common.exceptions import VimDriverNewtonException +from newton_base.util import VimDriverUtils + +logger = logging.getLogger(__name__) + +running_threads = {} +running_thread_lock = threading.Lock() + + +class Samples(APIView): + service = {'service_type': 'metering', + 'interface': 'public'} + keys_mapping = [ + ("project_id", "tenantId"), + ("disk_format", "sampleType"), + ("container_format", "containerFormat") + ] + + + def get(self, request, vimid="", tenantid="", sampleid=""): + logger.debug("samples--get::> %s" % request.data) + try: + query = VimDriverUtils.get_query_part(request) + req_resouce = "/v2/samples" + req_resouce = req_resouce + "?" + query + + vim = VimDriverUtils.get_vim_info(vimid) + vim["url"] = "http://192.168.106.200:5000/v3" + vim["domain"] = "Default" + sess = VimDriverUtils.get_session(vim, tenantid) + resp = sess.get(req_resouce, endpoint_filter=self.service) + content = resp.json() + vim_dict = { + "vimName": vim["name"], + "vimId": vim["vimId"], + "tenantId": tenantid, + } + return Response(data=content, status=resp.status_code) + except VimDriverNewtonException as e: + return Response(data={'error2': e.content}, status=e.status_code) + except HttpError as e: + logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) + return Response(data=e.response.json(), status=e.http_status) + except Exception as e: + logger.error(traceback.format_exc()) + return Response(data={'error4': str(e)}, + status=status.HTTP_500_INTERNAL_SERVER_ERROR) + + + def get_samples(self, query="", vimid="", tenantid="", sampleid=""): + logger.debug("samples--get_samples::> %s" % sampleid) + + req_resouce = "v2/samples" + if sampleid: + req_resouce += "/%s" % sampleid + elif query: + req_resouce += "?%s" % query + + vim = VimDriverUtils.get_vim_info(vimid) + sess = VimDriverUtils.get_session(vim, tenantid) + resp = sess.get(req_resouce, endpoint_filter=self.service) + content = resp.json() + vim_dict = { + "vimName": vim["name"], + "vimId": vim["vimId"], + "tenantId": tenantid, + } + content.update(vim_dict) + return content, resp.status_code + + diff --git a/share/newton_base/openoapi/vmlist.py b/share/newton_base/openoapi/vmlist.py new file mode 100755 index 00000000..8d2e0c6f --- /dev/null +++ b/share/newton_base/openoapi/vmlist.py @@ -0,0 +1,74 @@ +# Copyright 2018 CMCC Technologies Co.,Ltd +# +# 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 logging +import threading +import traceback +from keystoneauth1.exceptions import HttpError +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView + +from common.exceptions import VimDriverNewtonException +from newton_base.util import VimDriverUtils + +logger = logging.getLogger(__name__) + +running_threads = {} +running_thread_lock = threading.Lock() + + +class VMlist(APIView): + service = {'service_type': 'compute', + 'interface': 'public'} + keys_mapping = [ + ("project_id", "tenantId"), + ("disk_format", "serverType"), + ("container_format", "containerFormat") + ] + + def get(self, request, vimid="", tenantid="", serverid=""): + logger.debug("servers--get::> %s" % request.data) + try: + query = VimDriverUtils.get_query_part(request) + content, status_code = self.get_servers(query, vimid, tenantid, serverid) + return Response(data=content, status=status_code) + except VimDriverNewtonException as e: + return Response(data={'error': e.content}, status=e.status_code) + except HttpError as e: + logger.error("HttpError: status:%s, response:%s" % (e.http_status, e.response.json())) + return Response(data=e.response.json(), status=e.http_status) + except Exception as e: + logger.error(traceback.format_exc()) + return Response(data={'error': str(e)}, + status=status.HTTP_500_INTERNAL_SERVER_ERROR) + + + def get_servers(self, query="", vimid="", tenantid="", serverid=""): + logger.debug("servers--get_servers::> %s" % serverid) + + req_resouce = "/servers" + vim = VimDriverUtils.get_vim_info(vimid) + vim["domain"] = "Default" + sess = VimDriverUtils.get_session(vim, tenantid) + resp = sess.get(req_resouce, endpoint_filter=self.service) + content = resp.json() + vim_dict = { + "vimName": vim["name"], + "vimId": vim["vimId"], + "tenantId": tenantid, + } + + return content, resp.status_code + + -- cgit 1.2.3-korg