make version of ts_mon compatible with appengine

infra_libs/ts_mon/monitors.py

 # Copyright 2015 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """Classes representing the monitoring interface for tasks or devices.
 
 Usage:
   import argparse
   from infra_libs import ts_mon
 
@@ skipping 25 matching lines @@
 import json
 import logging
 import os
 
 from monacq import acquisition_api
 from monacq.proto import metrics_pb2
 
 from infra_libs import logs
 import infra_libs
 
-import httplib2
 from apiclient import discovery
 from oauth2client.client import GoogleCredentials
 from oauth2client.file import Storage
 from oauth2client.gce import AppAssertionCredentials
+import httplib2
 
 # Special string that can be passed through as the credentials path to use the
 # default GCE service account.
 GCE_CREDENTIALS = ':gce'
 
 
 def _logging_callback(resp, content):  # pragma: no cover
   logging.debug(repr(resp))
   logging.debug(content)
 
@@ skipping 79 matching lines @@
 
     with open(credentials_file_path, 'r') as credentials_file:
       credentials_json = json.load(credentials_file)
     if credentials_json.get('type', None):
       credentials = GoogleCredentials.from_stream(credentials_file_path)
       credentials = credentials.create_scoped(cls._SCOPES)
       return credentials
     return Storage(credentials_file_path).get()
 
   def _initialize(self, credsfile, project, topic, use_instrumented_http):
-    # Copied from acquisition_api.AcquisitionCredential.Load.
     creds = self._load_credentials(credsfile)
     if use_instrumented_http:
       self._http = infra_libs.InstrumentedHttp('acq-mon-api-pubsub')
     else:  # pragma: no cover
       self._http = httplib2.Http()
     creds.authorize(self._http)
     self._api = discovery.build('pubsub', 'v1', http=self._http)
     self._topic = 'projects/%s/topics/%s' % (project, topic)
 
   def __init__(self, credsfile, project, topic, use_instrumented_http=True):
@@ skipping 33 matching lines @@
     logs.add_handler(self._logger, handler=filehandler, level=logging.INFO)
 
   def send(self, metric_pb):
     self._logger.info('\n' + str(self._wrap_proto(metric_pb)))
 
 
 class NullMonitor(Monitor):
   """Class that doesn't send metrics anywhere."""
   def send(self, metric_pb):
     pass