Device component - Microwave Driver:

import json, logging, requests

from requests.auth import HTTPBasicAuth

from typing import Optional, Set

from typing import Dict, Optional, Set

from device.service.driver_api._Driver import RESOURCE_ENDPOINTS

LOGGER = logging.getLogger(__name__)

            return False

    return True

VLAN_CLASSIFICATION_TYPES = {'ietf-eth-tran-types:vlan-classification', 'vlan-classification'}

OUTER_TAG_C_TYPE = {'ietf-eth-tran-types:classify-c-vlan', 'classify-c-vlan'}

def get_vlan_outer_tag(endpoint : Dict) -> Optional[int]:

    if endpoint.get('service-classification-type', '') not in VLAN_CLASSIFICATION_TYPES: return None

    outer_tag = endpoint.get('outer-tag', {})

    if outer_tag.get('tag-type', '') not in OUTER_TAG_C_TYPE: return None

    return outer_tag.get('vlan-value')

def config_getter(

    root_url : str, resource_key : str, auth : Optional[HTTPBasicAuth] = None, timeout : Optional[int] = None,

    node_ids : Set[str] = set()

            for service in service_instances:

                service_name = service['etht-svc-name']

                resource_key = '/services/service[{:s}]'.format(service_name)

                result.append((resource_key, service))

                resource_value = {'uuid': service.get('etht-svc-name', '<UNDEFINED>')}

                for endpoint in service.get('etht-svc-end-points', []):

                    _vlan_id = get_vlan_outer_tag(endpoint)

                    if _vlan_id is not None:

                        vlan_id = resource_value.get('vlan_id')

                        if vlan_id is None:

                            resource_value['vlan_id'] = _vlan_id

                        elif vlan_id != _vlan_id:

                            raise Exception('Incompatible VLAN Ids: {:s}'.format(str(service)))

                    access_points = endpoint.get('etht-svc-access-points', [])

                    for access_point in access_points:

                        if access_point['access-point-id'] == '1':

                            resource_value['node_id_src'] = access_point['access-node-id']

                            resource_value['tp_id_src']   = access_point['access-ltp-id']

                        elif access_point['access-point-id'] == '2':

                            resource_value['node_id_dst'] = access_point['access-node-id']

                            resource_value['tp_id_dst']   = access_point['access-ltp-id']

                if len(node_ids) > 0 and resource_value['node_id_src'] not in node_ids: continue

                if len(node_ids) > 0 and resource_value['node_id_dst'] not in node_ids: continue

                result.append((resource_key, resource_value))

        except requests.exceptions.Timeout:

            LOGGER.exception('Timeout connecting {:s}'.format(url))

        except Exception as e:  # pylint: disable=broad-except