Merge "Added V0 Registry API"

27 files changed, 1132 insertions, 0 deletions

diff --git a/azure/multicloud_azure/pub/__init__.py b/azure/multicloud_azure/pub/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/__init__.py
diff --git a/azure/multicloud_azure/pub/config/__init__.py b/azure/multicloud_azure/pub/config/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/config/__init__.py
diff --git a/azure/multicloud_azure/pub/config/config.py b/azure/multicloud_azure/pub/config/config.py
new file mode 100644
index 0000000..db09fd6
--- /dev/null
+++ b/azure/multicloud_azure/pub/config/config.py
@@ -0,0 +1,41 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import os
+
+# [MSB]
+MSB_SERVICE_IP = "msb.onap.org"
+MSB_SERVICE_PORT = "10080"
+
+# [IMAGE LOCAL PATH]
+ROOT_PATH = os.path.dirname(os.path.dirname(
+    os.path.dirname(os.path.abspath(__file__))))
+
+# [A&AI]
+AAI_ADDR = "aai.api.simpledemo.openecomp.org"
+AAI_PORT = "8443"
+AAI_SERVICE_URL = 'https://%s:%s/aai' % (AAI_ADDR, AAI_PORT)
+AAI_SCHEMA_VERSION = "v13"
+AAI_USERNAME = "AAI"
+AAI_PASSWORD = "AAI"
+
+# [DMaaP]
+MR_ADDR = ""
+MR_PORT = ""
+
+# [MDC]
+SERVICE_NAME = "multicloud-azure"
+FORWARDED_FOR_FIELDS = ["HTTP_X_FORWARDED_FOR", "HTTP_X_FORWARDED_HOST",
+                        "HTTP_X_FORWARDED_SERVER"]
+
+# [Local Config]
+API_SERVER_PORT = 9004
diff --git a/azure/multicloud_azure/pub/config/log.yml b/azure/multicloud_azure/pub/config/log.yml
new file mode 100644
index 0000000..7bbc427
--- /dev/null
+++ b/azure/multicloud_azure/pub/config/log.yml
@@ -0,0 +1,26 @@
+version: 1
+disable_existing_loggers: False
+
+loggers:
+    azure:
+      handlers: [azure_handler]
+      level: "DEBUG"
+      propagate: False
+handlers:
+    azure_handler:
+        level: "DEBUG"
+        class: "logging.handlers.RotatingFileHandler"
+        filename: "/var/log/onap/multicloud/azure/azure.log"
+        formatter: "mdcFormat"
+        maxBytes: 52428800
+        backupCount: 10
+formatters:
+    standard:
+        format: "%(asctime)s|||||%(name)s||%(thread)||%(funcName)s||%(levelname)s||%(message)s"
+    mdcFormat:
+        format: "%(asctime)s|||||%(name)s||%(thread)s||%(funcName)s||%(levelname)s||%(message)s||||%(mdc)s \t"
+        mdcfmt: "{requestID} {invocationID} {serviceName} {serviceIP}"
+        datefmt: "%Y-%m-%d %H:%M:%S"
+        (): onaplogging.mdcformatter.MDCFormatter
+
+
diff --git a/azure/multicloud_azure/pub/database/__init__.py b/azure/multicloud_azure/pub/database/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/database/__init__.py
diff --git a/azure/multicloud_azure/pub/database/models.py b/azure/multicloud_azure/pub/database/models.py
new file mode 100644
index 0000000..757430b
--- /dev/null
+++ b/azure/multicloud_azure/pub/database/models.py
@@ -0,0 +1,23 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+from django.db import models
+
+
+class VimInstModel(models.Model):
+    class Meta:
+        db_table = 'vim_inst_type_mapping'
+
+    vimid = models.CharField(
+        db_column='VIMID', primary_key=True, max_length=200)
+    vimtype = models.CharField(db_column="VIMTYPE", max_length=200)
+    viminst_url = models.CharField(db_column="VIMINSTURL", max_length=200)
diff --git a/azure/multicloud_azure/pub/exceptions.py b/azure/multicloud_azure/pub/exceptions.py
new file mode 100644
index 0000000..3f38f2c
--- /dev/null
+++ b/azure/multicloud_azure/pub/exceptions.py
@@ -0,0 +1,66 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+
+class ClientException(Exception):
+
+    message = "ClientException"
+
+    def __init__(self, message=None):
+        self.message = message or self.message
+        super(ClientException, self).__init__(self.message)
+
+
+class ServerException(Exception):
+
+    message = "ServerException"
+
+    def __init__(self, message=None, status_code="", content=""):
+        super(ServerException, self).__init__(message)
+        self.message = message or self.message
+        self.status_code = status_code
+        self.content = content
+
+
+class RetriableConnectionFailure(Exception):
+    pass
+
+
+class ConnectionError(ClientException):
+    message = "Cannot connect to API service."
+
+
+class ConnectTimeout(ConnectionError, RetriableConnectionFailure):
+    message = "Timed out connecting to service."
+
+
+class ConnectFailure(ConnectionError, RetriableConnectionFailure):
+    message = "Connection failure that may be retried."
+
+
+class SSLError(ConnectionError):
+    message = "An SSL error occurred."
+
+
+class UnknownConnectionError(ConnectionError):
+
+    def __init__(self, msg, original):
+        super(UnknownConnectionError, self).__init__(msg)
+        self.original = original
+
+
+class NotFoundError(ServerException):
+    message = "Cannot find value"
+
+
+class VimDriverAzureException(ServerException):
+    message = "Cannot find  vim driver"
diff --git a/azure/multicloud_azure/pub/msapi/__init__.py b/azure/multicloud_azure/pub/msapi/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/msapi/__init__.py
diff --git a/azure/multicloud_azure/pub/msapi/extsys.py b/azure/multicloud_azure/pub/msapi/extsys.py
new file mode 100644
index 0000000..4d78337
--- /dev/null
+++ b/azure/multicloud_azure/pub/msapi/extsys.py
@@ -0,0 +1,47 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import logging
+
+from multicloud_azure.pub.utils.restcall import AAIClient
+
+logger = logging.getLogger(__name__)
+
+
+def split_vim_to_owner_region(vim_id):
+    split_vim = vim_id.split('_')
+    cloud_owner = split_vim[0]
+    cloud_region = "".join(split_vim[1:])
+    return cloud_owner, cloud_region
+
+
+def get_vim_by_id(vim_id):
+    cloud_owner, cloud_region = split_vim_to_owner_region(vim_id)
+    client = AAIClient(cloud_owner, cloud_region)
+    ret = client.get_vim(get_all=True)
+    esrInfo = ret['esr-system-info-list']['esr-system-info'][0]
+    data = {
+        'type': ret['cloud-type'],
+        'version': ret['cloud-region-version'],
+        'cloud_extra_info': ret['cloud-extra-info'],
+        'cloud_region_id': ret['cloud-region-id'],
+        'name': vim_id,
+        'username': esrInfo['user-name'],
+        'password': esrInfo['password'],
+        'default_tenant': esrInfo['default-tenant'],
+        'url': esrInfo['service-url'],
+        'domain': esrInfo['cloud-domain'],
+        'cacert': esrInfo.get('ssl-cacert', ""),
+        'insecure': esrInfo.get('ssl-insecure', False)
+    }
+    ret.update(data)
+    return ret
diff --git a/azure/multicloud_azure/pub/utils/__init__.py b/azure/multicloud_azure/pub/utils/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/__init__.py
diff --git a/azure/multicloud_azure/pub/utils/enumutil.py b/azure/multicloud_azure/pub/utils/enumutil.py
new file mode 100644
index 0000000..eb7a22c
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/enumutil.py
@@ -0,0 +1,15 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+
+def enum(**enums):
+    return type('Enum', (), enums)
diff --git a/azure/multicloud_azure/pub/utils/fileutil.py b/azure/multicloud_azure/pub/utils/fileutil.py
new file mode 100644
index 0000000..1868300
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/fileutil.py
@@ -0,0 +1,50 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+import os
+import shutil
+import logging
+import traceback
+import urllib2
+
+logger = logging.getLogger(__name__)
+
+
+def make_dirs(path):
+    if not os.path.exists(path):
+        os.makedirs(path, 0777)
+
+
+def delete_dirs(path):
+    try:
+        if os.path.exists(path):
+            shutil.rmtree(path)
+    except Exception as e:
+        logger.error(traceback.format_exc())
+        logger.error("Failed to delete %s:%s", path, e.message)
+
+
+def download_file_from_http(url, local_dir, file_name):
+    local_file_name = os.path.join(local_dir, file_name)
+    is_download_ok = False
+    try:
+        make_dirs(local_dir)
+        r = urllib2.Request(url)
+        req = urllib2.urlopen(r)
+        save_file = open(local_file_name, 'wb')
+        save_file.write(req.read())
+        save_file.close()
+        req.close()
+        is_download_ok = True
+    except Exception:
+        logger.error(traceback.format_exc())
+        logger.error("Failed to download %s to %s.", url, local_file_name)
+    return is_download_ok, local_file_name
diff --git a/azure/multicloud_azure/pub/utils/idutil.py b/azure/multicloud_azure/pub/utils/idutil.py
new file mode 100644
index 0000000..be6e8a0
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/idutil.py
@@ -0,0 +1,18 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+from redisco import containers as cont
+
+
+def get_auto_id(id_type, id_group="auto_id_hash"):
+    auto_id_hash = cont.Hash(id_group)
+    auto_id_hash.hincrby(id_type, 1)
+    return auto_id_hash.hget(id_type)
diff --git a/azure/multicloud_azure/pub/utils/restcall.py b/azure/multicloud_azure/pub/utils/restcall.py
new file mode 100644
index 0000000..984c425
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/restcall.py
@@ -0,0 +1,530 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import sys
+import traceback
+import logging
+import urllib2
+import uuid
+import httplib2
+import json
+
+from multicloud_azure.pub.config.config import AAI_SCHEMA_VERSION
+from multicloud_azure.pub.config.config import AAI_SERVICE_URL
+from multicloud_azure.pub.config.config import AAI_USERNAME
+from multicloud_azure.pub.config.config import AAI_PASSWORD
+from multicloud_azure.pub.config.config import MSB_SERVICE_IP, MSB_SERVICE_PORT
+
+from multicloud_azure.pub.exceptions import VimDriverAzureException
+
+rest_no_auth, rest_oneway_auth, rest_bothway_auth = 0, 1, 2
+HTTP_200_OK, HTTP_201_CREATED = '200', '201'
+HTTP_204_NO_CONTENT, HTTP_202_ACCEPTED = '204', '202'
+status_ok_list = [HTTP_200_OK, HTTP_201_CREATED,
+                  HTTP_204_NO_CONTENT, HTTP_202_ACCEPTED]
+HTTP_404_NOTFOUND, HTTP_403_FORBIDDEN = '404', '403'
+HTTP_401_UNAUTHORIZED, HTTP_400_BADREQUEST = '401', '400'
+
+logger = logging.getLogger(__name__)
+
+
+def call_req(base_url, user, passwd, auth_type, resource, method, content='',
+             headers=None):
+    callid = str(uuid.uuid1())
+#    logger.debug("[%s]call_req('%s','%s','%s',%s,'%s','%s','%s')" % (
+#        callid, base_url, user, passwd, auth_type, resource, method, content))
+    ret = None
+    resp_status = ''
+    resp = ""
+    full_url = ""
+
+    try:
+        full_url = combine_url(base_url, resource)
+        if headers is None:
+            headers = {}
+            headers['content-type'] = 'application/json'
+
+        if user:
+            headers['Authorization'] = 'Basic ' + \
+                ('%s:%s' % (user, passwd)).encode("base64")
+        ca_certs = None
+        for retry_times in range(3):
+            http = httplib2.Http(
+                ca_certs=ca_certs,
+                disable_ssl_certificate_validation=(
+                    auth_type == rest_no_auth))
+            http.follow_all_redirects = True
+            try:
+                logger.debug("request=%s" % full_url)
+                resp, resp_content = http.request(
+                    full_url, method=method.upper(), body=content,
+                    headers=headers)
+                resp_status = resp['status']
+                resp_body = resp_content.decode('UTF-8')
+
+                if resp_status in status_ok_list:
+                    ret = [0, resp_body, resp_status, resp]
+                else:
+                    ret = [1, resp_body, resp_status, resp]
+                break
+            except Exception as ex:
+                if 'httplib.ResponseNotReady' in str(sys.exc_info()):
+                    logger.error(traceback.format_exc())
+                    ret = [1, "Unable to connect to %s" % full_url,
+                           resp_status, resp]
+                    continue
+                raise ex
+    except urllib2.URLError as err:
+        ret = [2, str(err), resp_status, resp]
+    except Exception as ex:
+        logger.error(traceback.format_exc())
+        logger.error("[%s]ret=%s" % (callid, str(sys.exc_info())))
+        res_info = str(sys.exc_info())
+        if 'httplib.ResponseNotReady' in res_info:
+            res_info = ("The URL[%s] request failed or is not responding." %
+                        full_url)
+        ret = [3, res_info, resp_status, resp]
+#    logger.debug("[%s]ret=%s" % (callid, str(ret)))
+    return ret
+
+
+def req_by_msb(resource, method, content=''):
+    base_url = "http://%s:%s/" % (MSB_SERVICE_IP, MSB_SERVICE_PORT)
+    return call_req(base_url, "", "", rest_no_auth, resource, method, content)
+
+
+def combine_url(base_url, resource):
+    full_url = None
+    if base_url.endswith('/') and resource.startswith('/'):
+        full_url = base_url[:-1] + resource
+    elif base_url.endswith('/') and not resource.startswith('/'):
+        full_url = base_url + resource
+    elif not base_url.endswith('/') and resource.startswith('/'):
+        full_url = base_url + resource
+    else:
+        full_url = base_url + '/' + resource
+    return full_url
+
+
+def get_res_from_aai(resource, content=''):
+    headers = {
+        'X-FromAppId': 'MultiCloud',
+        'X-TransactionId': '9001',
+        'content-type': 'application/json',
+        'accept': 'application/json'
+    }
+    base_url = "%s/%s" % (AAI_SERVICE_URL, AAI_SCHEMA_VERSION)
+    return call_req(base_url, AAI_USERNAME, AAI_PASSWORD, rest_no_auth,
+                    resource, "GET", content, headers)
+
+
+class AAIClient(object):
+    def __init__(self, cloud_owner, cloud_region):
+        self.base_url = "%s/%s" % (AAI_SERVICE_URL, AAI_SCHEMA_VERSION)
+        self.username = AAI_USERNAME
+        self.password = AAI_PASSWORD
+        self.default_headers = {
+            'X-FromAppId': 'multicloud-azure',
+            'X-TransactionId': '9004',
+            'content-type': 'application/json',
+            'accept': 'application/json'
+        }
+        self.cloud_owner = cloud_owner
+        self.cloud_region = cloud_region
+        self._vim_info = None
+
+    def get_vim(self, get_all=False):
+        resource = ("/cloud-infrastructure/cloud-regions/cloud-region"
+                    "/%s/%s" % (self.cloud_owner, self.cloud_region))
+        if get_all:
+            resource = "%s?depth=all" % resource
+        resp = call_req(self.base_url, self.username, self.password,
+                        rest_no_auth, resource, "GET",
+                        headers=self.default_headers)
+        if resp[0] != 0:
+            raise VimDriverAzureException(
+                status_code=404,
+                content="Failed to query VIM with id (%s_%s) from extsys." % (
+                    self.cloud_owner, self.cloud_region))
+        return json.loads(resp[1])
+
+    def delete_vim(self):
+        resp = self.get_vim(get_all=True)
+        logger.debug('Delete cloud region')
+        resource = ("/cloud-infrastructure/cloud-regions/cloud-region"
+                    "/%s/%s?resource-version=%s" %
+                    (self.cloud_owner, self.cloud_region,
+                     resp['resource-version']))
+        resp = call_req(self.base_url, self.username, self.password,
+                        rest_no_auth, resource, "DELETE",
+                        headers=self.default_headers)
+        if resp[0] != 0:
+            raise VimDriverAzureException(
+                status_code=400,
+                content="Failed to delete cloud %s_%s: %s." % (
+                    self.cloud_owner, self.cloud_region, resp[1]))
+
+    def update_vim(self, content):
+        self.add_flavors(content)
+
+    def update_identity_url(self):
+        vim = self.get_vim()
+        vim['identity-url'] = ("http://%s/api/multicloud/v0/%s_%s/identity/"
+                               "v3" % (MSB_SERVICE_IP, self.cloud_owner,
+                                       self.cloud_region))
+        resource = ("/cloud-infrastructure/cloud-regions/cloud-region"
+                    "/%s/%s" % (self.cloud_owner, self.cloud_region))
+        logger.debug("Updating identity url %s" % vim)
+        call_req(self.base_url, self.username, self.password,
+                 rest_no_auth, resource, "PUT",
+                 content=json.dumps(vim),
+                 headers=self.default_headers)
+
+    def add_flavors(self, content):
+        for flavor in content['flavors']:
+            resource = ("/cloud-infrastructure/cloud-regions/cloud-region/"
+                        "%s/%s/flavors/flavor/%s" % (
+                            self.cloud_owner, self.cloud_region,
+                            flavor['name']))
+            body = {
+                'flavor-name': flavor['name'],
+                'flavor-vcpus': flavor['vcpus'],
+                'flavor-ram': flavor['ram'],
+                'flavor-disk': flavor['disk'],
+                'flavor-selflink': ""
+            }
+            # Handle extra specs
+            if flavor['name'].startswith("onap."):
+                hpa_capabilities = self._get_hpa_capabilities(
+                    flavor)
+                body['hpa-capabilities'] = {
+                    'hpa-capability': hpa_capabilities}
+
+            logger.debug("Adding flavors to cloud region")
+            call_req(self.base_url, self.username, self.password,
+                     rest_no_auth, resource, "PUT",
+                     content=json.dumps(body),
+                     headers=self.default_headers)
+
+    def _get_hpa_capabilities(self, flavor):
+        hpa_caps = []
+
+        # Basic capabilties
+        caps_dict = self._get_hpa_basic_capabilities(flavor)
+        if len(caps_dict) > 0:
+            logger.debug("basic_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # cpupining capabilities
+        caps_dict = self._get_cpupinning_capabilities(flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("cpupining_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # cputopology capabilities
+        caps_dict = self._get_cputopology_capabilities(flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("cputopology_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # hugepages capabilities
+        caps_dict = self._get_hugepages_capabilities(flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("hugepages_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # numa capabilities
+        caps_dict = self._get_numa_capabilities(flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("numa_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # storage capabilities
+        caps_dict = self._get_storage_capabilities(flavor)
+        if len(caps_dict) > 0:
+            logger.debug("storage_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # CPU instruction set extension capabilities
+        caps_dict = self._get_instruction_set_capabilities(
+            flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("instruction_set_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # PCI passthrough capabilities
+        caps_dict = self._get_pci_passthrough_capabilities(
+            flavor['extra_specs'])
+        if len(caps_dict) > 0:
+            logger.debug("pci_passthrough_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        # ovsdpdk capabilities
+        caps_dict = self._get_ovsdpdk_capabilities()
+        if len(caps_dict) > 0:
+            logger.debug("ovsdpdk_capabilities_info: %s" % caps_dict)
+            hpa_caps.append(caps_dict)
+
+        return hpa_caps
+
+    def _get_hpa_basic_capabilities(self, flavor):
+        basic_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        basic_capability['hpa-capability-id'] = str(feature_uuid)
+        basic_capability['hpa-feature'] = 'basicCapabilities'
+        basic_capability['architecture'] = 'generic'
+        basic_capability['hpa-version'] = 'v1'
+
+        basic_capability['hpa-feature-attributes'] = []
+        basic_capability['hpa-feature-attributes'].append({
+            'hpa-attribute-key': 'numVirtualCpu',
+            'hpa-attribute-value': json.dumps(
+                {'value': str(flavor['vcpus'])})})
+        basic_capability['hpa-feature-attributes'].append({
+            'hpa-attribute-key': 'virtualMemSize',
+            'hpa-attribute-value': json.dumps({'value': str(
+                flavor['ram']), 'unit': 'GB'})})
+
+        return basic_capability
+
+    def _get_cpupinning_capabilities(self, extra_specs):
+        cpupining_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if (extra_specs.get('hw:cpu_policy') or
+                extra_specs.get('hw:cpu_thread_policy')):
+            cpupining_capability['hpa-capability-id'] = str(feature_uuid)
+            cpupining_capability['hpa-feature'] = 'cpuPinning'
+            cpupining_capability['architecture'] = 'generic'
+            cpupining_capability['hpa-version'] = 'v1'
+
+            cpupining_capability['hpa-feature-attributes'] = []
+            if extra_specs.get('hw:cpu_thread_policy'):
+                cpupining_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'logicalCpuThreadPinningPolicy',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:cpu_thread_policy'])})})
+            if extra_specs.get('hw:cpu_policy'):
+                cpupining_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'logicalCpuPinningPolicy',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:cpu_policy'])})})
+
+        return cpupining_capability
+
+    def _get_cputopology_capabilities(self, extra_specs):
+        cputopology_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if (extra_specs.get('hw:cpu_sockets') or
+                extra_specs.get('hw:cpu_cores') or
+                extra_specs.get('hw:cpu_threads')):
+            cputopology_capability['hpa-capability-id'] = str(feature_uuid)
+            cputopology_capability['hpa-feature'] = 'cpuTopology'
+            cputopology_capability['architecture'] = 'generic'
+            cputopology_capability['hpa-version'] = 'v1'
+
+            cputopology_capability['hpa-feature-attributes'] = []
+            if extra_specs.get('hw:cpu_sockets'):
+                cputopology_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'numCpuSockets',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:cpu_sockets'])})})
+            if extra_specs.get('hw:cpu_cores'):
+                cputopology_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'numCpuCores',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:cpu_cores'])})})
+            if extra_specs.get('hw:cpu_threads'):
+                cputopology_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'numCpuThreads',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:cpu_threads'])})})
+
+        return cputopology_capability
+
+    def _get_hugepages_capabilities(self, extra_specs):
+        hugepages_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if extra_specs.get('hw:mem_page_size'):
+            hugepages_capability['hpa-capability-id'] = str(feature_uuid)
+            hugepages_capability['hpa-feature'] = 'hugePages'
+            hugepages_capability['architecture'] = 'generic'
+            hugepages_capability['hpa-version'] = 'v1'
+
+            hugepages_capability['hpa-feature-attributes'] = []
+            if extra_specs['hw:mem_page_size'] == 'large':
+                hugepages_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'memoryPageSize',
+                    'hpa-attribute-value': json.dumps(
+                        {'value': '2', 'unit': 'MB'})})
+            elif extra_specs['hw:mem_page_size'] == 'small':
+                hugepages_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'memoryPageSize',
+                    'hpa-attribute-value': json.dumps(
+                        {'value': '4', 'unit': 'KB'})})
+            elif extra_specs['hw:mem_page_size'] == 'any':
+                logger.info("Currently HPA feature memoryPageSize "
+                            "did not support 'any' page!!")
+            else:
+                hugepages_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': 'memoryPageSize',
+                    'hpa-attribute-value': json.dumps({'value': str(
+                        extra_specs['hw:mem_page_size']), 'unit': 'KB'})
+                    })
+
+        return hugepages_capability
+
+    def _get_numa_capabilities(self, extra_specs):
+        numa_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if extra_specs.get('hw:numa_nodes'):
+            numa_capability['hpa-capability-id'] = str(feature_uuid)
+            numa_capability['hpa-feature'] = 'numa'
+            numa_capability['architecture'] = 'generic'
+            numa_capability['hpa-version'] = 'v1'
+
+            numa_capability['hpa-feature-attributes'] = []
+            numa_capability['hpa-feature-attributes'].append({
+                'hpa-attribute-key': 'numaNodes',
+                'hpa-attribute-value': json.dumps({'value': str(
+                    extra_specs['hw:numa_nodes'])})
+                })
+
+            for num in range(0, int(extra_specs['hw:numa_nodes'])):
+                numa_cpu_node = "hw:numa_cpus.%s" % num
+                numa_mem_node = "hw:numa_mem.%s" % num
+                numacpu_key = "numaCpu-%s" % num
+                numamem_key = "numaMem-%s" % num
+
+                if (extra_specs.get(numa_cpu_node) and
+                        extra_specs.get(numa_mem_node)):
+                    numa_capability['hpa-feature-attributes'].append({
+                        'hpa-attribute-key': numacpu_key,
+                        'hpa-attribute-value': json.dumps({'value': str(
+                            extra_specs[numa_cpu_node])})
+                        })
+                    numa_capability['hpa-feature-attributes'].append({
+                        'hpa-attribute-key': numamem_key,
+                        'hpa-attribute-value': json.dumps({'value': str(
+                            extra_specs[numa_mem_node]), 'unit': 'MB'})
+                        })
+
+        return numa_capability
+
+    def _get_storage_capabilities(self, flavor):
+        storage_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        storage_capability['hpa-capability-id'] = str(feature_uuid)
+        storage_capability['hpa-feature'] = 'localStorage'
+        storage_capability['architecture'] = 'generic'
+        storage_capability['hpa-version'] = 'v1'
+
+        storage_capability['hpa-feature-attributes'] = []
+        storage_capability['hpa-feature-attributes'].append({
+            'hpa-attribute-key': 'diskSize',
+            'hpa-attribute-value': json.dumps({'value': str(
+                flavor['disk']), 'unit': 'MB'})
+            })
+        storage_capability['hpa-feature-attributes'].append({
+            'hpa-attribute-key': 'swapMemSize',
+            'hpa-attribute-value': json.dumps({'value': str(
+                flavor.get('swap', 0)), 'unit': 'MB'})
+            })
+        storage_capability['hpa-feature-attributes'].append({
+            'hpa-attribute-key': 'ephemeralDiskSize',
+            'hpa-attribute-value': json.dumps({'value': str(
+                flavor.get('OS-FLV-EXT-DATA:ephemeral', 0)), 'unit': 'GB'})
+            })
+        return storage_capability
+
+    def _get_instruction_set_capabilities(self, extra_specs):
+        instruction_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if extra_specs.get('hw:capabilities:cpu_info:features'):
+            instruction_capability['hpa-capability-id'] = str(feature_uuid)
+            instruction_capability['hpa-feature'] = 'instructionSetExtensions'
+            instruction_capability['architecture'] = 'Intel64'
+            instruction_capability['hpa-version'] = 'v1'
+
+            instruction_capability['hpa-feature-attributes'] = []
+            instruction_capability['hpa-feature-attributes'].append({
+                'hpa-attribute-key': 'instructionSetExtensions',
+                'hpa-attribute-value': json.dumps(
+                    {'value': extra_specs[
+                        'hw:capabilities:cpu_info:features']})
+                })
+        return instruction_capability
+
+    def _get_pci_passthrough_capabilities(self, extra_specs):
+        instruction_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if extra_specs.get('pci_passthrough:alias'):
+            value1 = extra_specs['pci_passthrough:alias'].split(':')
+            value2 = value1[0].split('-')
+
+            instruction_capability['hpa-capability-id'] = str(feature_uuid)
+            instruction_capability['hpa-feature'] = 'pciePassthrough'
+            instruction_capability['architecture'] = str(value2[2])
+            instruction_capability['hpa-version'] = 'v1'
+
+            instruction_capability['hpa-feature-attributes'] = []
+            instruction_capability['hpa-feature-attributes'].append({
+                'hpa-attribute-key': 'pciCount',
+                'hpa-attribute-value': json.dumps({'value': value1[1]})
+                })
+            instruction_capability['hpa-feature-attributes'].append({
+                'hpa-attribute-key': 'pciVendorId',
+                'hpa-attribute-value': json.dumps({'value': value2[3]})
+                })
+            instruction_capability['hpa-feature-attributes'].append({
+                'hpa-attribute-key': 'pciDeviceId',
+                'hpa-attribute-value': json.dumps({'value': value2[4]})
+                })
+
+        return instruction_capability
+
+    def _get_ovsdpdk_capabilities(self):
+        ovsdpdk_capability = {}
+        feature_uuid = uuid.uuid4()
+
+        if not self._vim_info:
+            self._vim_info = self.get_vim(get_all=True)
+        cloud_extra_info_str = self._vim_info.get('cloud-extra-info')
+        if not isinstance(cloud_extra_info_str, dict):
+            try:
+                cloud_extra_info_str = json.loads(cloud_extra_info_str)
+            except Exception as ex:
+                logger.error("Can not convert cloud extra info %s %s" % (
+                             str(ex), cloud_extra_info_str))
+                return {}
+        if cloud_extra_info_str:
+            cloud_dpdk_info = cloud_extra_info_str.get("ovsDpdk")
+            if cloud_dpdk_info:
+                ovsdpdk_capability['hpa-capability-id'] = str(feature_uuid)
+                ovsdpdk_capability['hpa-feature'] = 'ovsDpdk'
+                ovsdpdk_capability['architecture'] = 'Intel64'
+                ovsdpdk_capability['hpa-version'] = 'v1'
+
+                ovsdpdk_capability['hpa-feature-attributes'] = []
+                ovsdpdk_capability['hpa-feature-attributes'].append({
+                    'hpa-attribute-key': str(cloud_dpdk_info.get("libname")),
+                    'hpa-attribute-value': json.dumps(
+                        {'value': cloud_dpdk_info.get("libversion")})
+                    })
+        return ovsdpdk_capability
diff --git a/azure/multicloud_azure/pub/utils/syscomm.py b/azure/multicloud_azure/pub/utils/syscomm.py
new file mode 100644
index 0000000..f838956
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/syscomm.py
@@ -0,0 +1,111 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import inspect
+import json
+from collections import defaultdict
+from rest_framework import status
+
+
+keystoneV2Json = \
+    {
+        "auth": {
+            "tenantName": "",
+            "passwordCredentials": {
+                "username": "",
+                "password": ""
+            }
+        }
+    }
+
+
+SUCCESS_STATE = [status.HTTP_200_OK, status.HTTP_201_CREATED,
+                 status.HTTP_202_ACCEPTED]
+
+
+def fun_name():
+    return inspect.stack()[1][3]
+
+
+def jsonResponse(data, encoding='utf-8'):
+
+    content_type = "application/json"
+    try:
+        res = json.loads(data, encoding=encoding)
+    except Exception:
+        res = data
+        content_type = "text/plain"
+    return (res, content_type)
+
+
+class Catalogs(object):
+
+    def __init__(self):
+        self.ct = defaultdict(dict)
+
+    def storeEndpoint(self, vimid, endpoints):
+        if vimid in self.ct:
+            self.ct[vimid].update(endpoints)
+        else:
+            self.ct.setdefault(vimid, endpoints)
+
+    def getEndpointBy(self, vimid, serverType, interface='public'):
+
+        vim = self.ct.get(vimid)
+        return vim.get(serverType).get(interface, "") if vim else ""
+
+
+def verifyKeystoneV2(param):
+
+    return _walk_json(param, keystoneV2Json)
+
+
+# comapare two json by key
+def _walk_json(data, data2):
+    if isinstance(data, dict) and isinstance(data2, dict):
+        if set(data.keys()) != set(data2.keys()):
+            return False
+        else:
+            v1 = data.values()
+            v2 = data2.values()
+            v1.sort()
+            v2.sort()
+            if len(v1) != len(v2):
+                return False
+            for (i, j) in zip(v1, v2):
+                # continue compare key
+                if isinstance(i, dict) and isinstance(j, dict):
+                    if not _walk_json(i, j):
+                        return False
+                # ignore value
+                else:
+                    continue
+
+            return True
+
+    return False
+
+
+def keystoneVersion(url, version="v3"):
+
+    tmp = url.split("/")
+    v = tmp[-1]
+    if v not in ["v2.0", "v3"]:
+        url += "/" + version
+    else:
+        tmp[-1] = version
+        url = "/".join(tmp)
+
+    return url
+
+
+catalog = Catalogs()
diff --git a/azure/multicloud_azure/pub/utils/timeutil.py b/azure/multicloud_azure/pub/utils/timeutil.py
new file mode 100644
index 0000000..d5ef329
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/timeutil.py
@@ -0,0 +1,17 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import datetime
+
+
+def now_time(fmt="%Y-%m-%d %H:%M:%S"):
+    return datetime.datetime.now().strftime(fmt)
diff --git a/azure/multicloud_azure/pub/utils/values.py b/azure/multicloud_azure/pub/utils/values.py
new file mode 100644
index 0000000..61d7114
--- /dev/null
+++ b/azure/multicloud_azure/pub/utils/values.py
@@ -0,0 +1,22 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+
+def ignore_case_get(args, key, def_val=""):
+    if not key:
+        return def_val
+    if key in args:
+        return args[key]
+    for old_key in args:
+        if old_key.upper() == key.upper():
+            return args[old_key]
+    return def_val
diff --git a/azure/multicloud_azure/pub/vim/__init__.py b/azure/multicloud_azure/pub/vim/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/__init__.py
diff --git a/azure/multicloud_azure/pub/vim/const.py b/azure/multicloud_azure/pub/vim/const.py
new file mode 100644
index 0000000..dc5a3a4
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/const.py
@@ -0,0 +1,14 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+
+SAMPLE_KEY = "sample_value"
diff --git a/azure/multicloud_azure/pub/vim/vimapi/__init__.py b/azure/multicloud_azure/pub/vim/vimapi/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimapi/__init__.py
diff --git a/azure/multicloud_azure/pub/vim/vimapi/baseclient.py b/azure/multicloud_azure/pub/vim/vimapi/baseclient.py
new file mode 100644
index 0000000..4a9844b
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimapi/baseclient.py
@@ -0,0 +1,42 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import logging
+
+from multicloud_azure.pub.vim.vimsdk.azure_credentials import ClientObj
+from azure.mgmt.compute import ComputeManagementClient
+from azure.mgmt.resource import ResourceManagementClient
+
+LOG = logging.getLogger(__name__)
+
+
+class baseclient(object):
+
+    def __init__(self, **kwargs):
+        self._compute = None
+        self._resource = None
+
+    def get_compute_client(self, params):
+        if self._compute is not None:
+            return self._compute
+        credentials = ClientObj().get_client_obj(params)
+        self._compute = ComputeManagementClient(
+            credentials, params['subscription_id'])
+        return self._compute
+
+    def get_resource_client(self, params):
+        if self._resource is not None:
+            return self._resource
+        credentials = ClientObj.get_client_obj(params)
+        self._resource = ResourceManagementClient(
+            credentials, params['subscription_id'])
+        return self._resource
diff --git a/azure/multicloud_azure/pub/vim/vimapi/compute/OperateCompute.py b/azure/multicloud_azure/pub/vim/vimapi/compute/OperateCompute.py
new file mode 100644
index 0000000..799a0d1
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimapi/compute/OperateCompute.py
@@ -0,0 +1,29 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import logging
+
+from multicloud_azure.pub.vim.vimapi.baseclient import baseclient
+
+
+logger = logging.getLogger(__name__)
+
+
+class OperateCompute(baseclient):
+
+    def __init__(self, **kwargs):
+        super(OperateCompute, self).__init__(**kwargs)
+
+    def request(self, op, data, **kwargs):
+        compute = self.get_compute_client(data)
+        func = getattr(compute, op)
+        return func
diff --git a/azure/multicloud_azure/pub/vim/vimapi/compute/OperateFlavors.py b/azure/multicloud_azure/pub/vim/vimapi/compute/OperateFlavors.py
new file mode 100644
index 0000000..827366b
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimapi/compute/OperateFlavors.py
@@ -0,0 +1,33 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+import logging
+
+from OperateCompute import OperateCompute
+from multicloud_azure.swagger import compute_utils
+logger = logging.getLogger(__name__)
+
+
+class OperateFlavors(OperateCompute):
+
+    def __init__(self, **kwargs):
+        super(OperateFlavors, self).__init__(**kwargs)
+
+    def list_flavors(self, data, **query):
+        logger.info("Inside OperateFlavors.list_flavors ")
+        flavors = self.request('virtual_machine_sizes', data, **query)
+        flavors = flavors.list(data['region_id'])
+        vmSizes = []
+        for flavor in flavors:
+            result = compute_utils.convert_vmsize_aai(flavor)
+            vmSizes.append(result)
+        return vmSizes
diff --git a/azure/multicloud_azure/pub/vim/vimapi/compute/__init__.py b/azure/multicloud_azure/pub/vim/vimapi/compute/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimapi/compute/__init__.py
diff --git a/azure/multicloud_azure/pub/vim/vimsdk/__init__.py b/azure/multicloud_azure/pub/vim/vimsdk/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimsdk/__init__.py
diff --git a/azure/multicloud_azure/pub/vim/vimsdk/azure_credentials.py b/azure/multicloud_azure/pub/vim/vimsdk/azure_credentials.py
new file mode 100644
index 0000000..e66ac7b
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimsdk/azure_credentials.py
@@ -0,0 +1,28 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+from azure.common.credentials import ServicePrincipalCredentials
+
+
+class ClientObj(object):
+
+    def get_client_obj(self, params):
+        if params is None:
+            params = {}
+        TENANT_ID = params['tenant_id']
+        CLIENT = params['username']
+        KEY = params['password']
+
+        credentials = ServicePrincipalCredentials(client_id=CLIENT,
+                                                  secret=KEY, tenant=TENANT_ID)
+
+        return credentials
diff --git a/azure/multicloud_azure/pub/vim/vimsdk/sdk.py b/azure/multicloud_azure/pub/vim/vimsdk/sdk.py
new file mode 100644
index 0000000..c716620
--- /dev/null
+++ b/azure/multicloud_azure/pub/vim/vimsdk/sdk.py
@@ -0,0 +1,20 @@
+# Copyright (c) 2018 Amdocs
+#
+# 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.
+
+from multicloud_azure.pub.vim.vimapi.baseclient import baseclient
+
+
+def create_connection(params):
+    if params is None:
+        params = {}
+    client = baseclient.get_compute_client(params)
+    return client