ソースを参照

Disable file_cache warnings, network renaming bugs

discovery complains that file_cache is not available when using
oauth2client >= 4.00. These warnings are disabled.

In some places we still use provider.network.blabla which now should be
provider.networking.networks.blabla.
Ehsan Chiniforooshan 8 年 前
コミット
095b5c0453

+ 9 - 3
cloudbridge/cloud/providers/gce/provider.py

@@ -3,6 +3,7 @@ Provider implementation based on google-api-python-client library
 for GCE.
 for GCE.
 """
 """
 import json
 import json
+import logging
 import os
 import os
 import re
 import re
 import time
 import time
@@ -167,12 +168,17 @@ class GCECloudProvider(BaseCloudProvider):
     def __init__(self, config):
     def __init__(self, config):
         super(GCECloudProvider, self).__init__(config)
         super(GCECloudProvider, self).__init__(config)
 
 
+        # Disable warnings about file_cache not being available when using
+        # oauth2client >= 4.0.0.
+        logging.getLogger('googleapicliet.discovery_cache').setLevel(
+                logging.ERROR)
+
         # Initialize cloud connection fields
         # Initialize cloud connection fields
         self.credentials_file = self._get_config_value(
         self.credentials_file = self._get_config_value(
-            'gce_service_creds_file', os.environ.get('GCE_SERVICE_CREDS_FILE'))
+                'gce_service_creds_file', os.environ.get('GCE_SERVICE_CREDS_FILE'))
         self.credentials_dict = self._get_config_value(
         self.credentials_dict = self._get_config_value(
-            'gce_service_creds_dict',
-            json.loads(os.getenv('GCE_SERVICE_CREDS_DICT', '{}')))
+                'gce_service_creds_dict',
+                json.loads(os.getenv('GCE_SERVICE_CREDS_DICT', '{}')))
         # If 'gce_service_creds_dict' is not passed in from config and
         # If 'gce_service_creds_dict' is not passed in from config and
         # self.credentials_file is available, read and parse the json file to
         # self.credentials_file is available, read and parse the json file to
         # self.credentials_dict.
         # self.credentials_dict.

+ 10 - 7
cloudbridge/cloud/providers/gce/services.py

@@ -232,20 +232,21 @@ class GCEVMFirewallService(BaseVMFirewallService):
         tag, network_name = self._delegate.get_tag_network_from_id(group_id)
         tag, network_name = self._delegate.get_tag_network_from_id(group_id)
         if tag is None:
         if tag is None:
             return None
             return None
-        network = self.provider.network.get_by_name(network_name)
+        network = self.provider.networking.networks.get_by_name(network_name)
         return GCEVMFirewall(self._delegate, tag, network)
         return GCEVMFirewall(self._delegate, tag, network)
 
 
     def list(self, limit=None, marker=None):
     def list(self, limit=None, marker=None):
         vm_firewalls = []
         vm_firewalls = []
         for tag, network_name in self._delegate.tag_networks:
         for tag, network_name in self._delegate.tag_networks:
-            network = self.provider.network.get_by_name(network_name)
+            network = self.provider.networking.networks.get_by_name(
+                    network_name)
             vm_firewall = GCEVMFirewall(self._delegate, tag, network)
             vm_firewall = GCEVMFirewall(self._delegate, tag, network)
             vm_firewalls.append(vm_firewall)
             vm_firewalls.append(vm_firewall)
         return ClientPagedResultList(self.provider, vm_firewalls,
         return ClientPagedResultList(self.provider, vm_firewalls,
                                      limit=limit, marker=marker)
                                      limit=limit, marker=marker)
 
 
     def create(self, name, description, network_id=None):
     def create(self, name, description, network_id=None):
-        network = self.provider.network.get(network_id)
+        network = self.provider.networking.networks.get(network_id)
         return GCEVMFirewall(self._delegate, name, network, description)
         return GCEVMFirewall(self._delegate, name, network, description)
 
 
     def find(self, name, limit=None, marker=None):
     def find(self, name, limit=None, marker=None):
@@ -257,7 +258,8 @@ class GCEVMFirewallService(BaseVMFirewallService):
         out = []
         out = []
         for tag, network_name in self._delegate.tag_networks:
         for tag, network_name in self._delegate.tag_networks:
             if tag == name:
             if tag == name:
-                network = self.provider.network.get_by_name(network_name)
+                network = self.provider.networking.networks.get_by_name(
+                        network_name)
                 out.append(GCEVMFirewall(self._delegate, name, network))
                 out.append(GCEVMFirewall(self._delegate, name, network))
         return out
         return out
 
 
@@ -275,7 +277,7 @@ class GCEVMFirewallService(BaseVMFirewallService):
                 continue
                 continue
             if tag not in tags:
             if tag not in tags:
                 continue
                 continue
-            network = self.provider.network.get_by_name(net_name)
+            network = self.provider.networking.networks.get_by_name(net_name)
             vm_firewalls.append(
             vm_firewalls.append(
                 GCEVMFirewall(self._delegate, tag, network))
                 GCEVMFirewall(self._delegate, tag, network))
         return vm_firewalls
         return vm_firewalls
@@ -466,7 +468,8 @@ class GCEInstanceService(BaseInstanceService):
             zone = self.provider.default_zone
             zone = self.provider.default_zone
         if not launch_config:
         if not launch_config:
             if subnet:
             if subnet:
-                network = self.provider.network.get(subnet.network_id)
+                network = self.provider.networking.networks.get(
+                        subnet.network_id)
                 network_url = (network.resource_url
                 network_url = (network.resource_url
                                if isinstance(network, GCENetwork) else network)
                                if isinstance(network, GCENetwork) else network)
             else:
             else:
@@ -974,7 +977,7 @@ class GCESubnetService(BaseSubnetService):
         returns the subnetwork of the default network that spans the given
         returns the subnetwork of the default network that spans the given
         zone.
         zone.
         """
         """
-        network = self.provider.network.get_or_create_default()
+        network = self.provider.networking.networks.get_or_create_default()
         subnets = self.list(network, zone)
         subnets = self.list(network, zone)
         if len(subnets) > 1:
         if len(subnets) > 1:
             cb.log.warning('The default network has more than one subnetwork '
             cb.log.warning('The default network has more than one subnetwork '