Python logging 模块，error() 实例源码

我们从Python开源项目中，提取了以下50个代码示例，用于说明如何使用logging.error()。

项目：PowerSpikeGG 作者：PowerSpikeGG | 项目源码 | 文件源码

def _connect(self, address, lazy_connection=False):
        """Set up a connection to the MongoDB server.

        Parameters:
            address: MongoDB server address.
            lazy_connection: avoid testing if the connection is working while
                initializing it.
        """
        client = pymongo.MongoClient(address,
            serverSelectionTimeoutMS=FLAGS.mongodb_connection_timeout)
        if lazy_connection:
            return client

        # Send a query to the server to see if the connection is working.
        try:
            client.server_info()
        except pymongo.errors.ServerSelectionTimeoutError as e:
            logging.error("Unable to connect to %s.", address)
            client = None

        return client

项目：charm-plumgrid-gateway 作者：openstack | 项目源码 | 文件源码

def load_config():
    '''
    Walk backwords from __file__ looking for config.yaml, load and return the
    'options' section'
    '''
    config = None
    f = __file__
    while config is None:
        d = os.path.dirname(f)
        if os.path.isfile(os.path.join(d, 'config.yaml')):
            config = os.path.join(d, 'config.yaml')
            break
        f = d

    if not config:
        logging.error('Could not find config.yaml in any parent directory '
                      'of %s. ' % file)
        raise Exception

    return yaml.safe_load(open(config).read())['options']

项目：core-framework 作者：RedhawkSDR | 项目源码 | 文件源码

def createOrb():
    '''
    Calls the omniorbpy CORBA.ORB_init() method in a thread.  Calling the method in a thread
    allows us to set a timeout for the ORB_init() call, as it will never return if the system
    has run out of threads.

    Return None on failure.
    '''
    # create a queue with one slot to hold the orb
    queue = Queue(maxsize=1) 

    def orbCreator():
        """
        A method to pass to callOmniorbpyWithTimeout.

        """

        orb = CORBA.ORB_init()
        queue.put(orb)

    orb = callOmniorbpyWithTimeout(orbCreator, queue)
    if orb == None:
        logging.error("omniorbpy failed to return from ORB_init.  This is often a result of an insufficient amount of threads available on the system.")
        sys.exit(-1)
    return orb

项目：OldMunkiPackages 作者：aysiu | 项目源码 | 文件源码

def trash_old_stuff(trashlist, trashpath, newpath):
    if isinstance(trashlist, list):
        for old_location in trashlist:
            # Get the subfolders needed to be created
            path_within_destination=os.path.relpath(old_location, trashpath)
            # Create what will be the destination path
            new_location=os.path.join(newpath, path_within_destination)
            # Make sure all the relevant subfolders exist in the destination
            if not os.path.exists(os.path.dirname(new_location)):
                os.makedirs(os.path.dirname(new_location))
            # Even though we've been double-checking paths all along, let's just make one last check
            if os.path.exists(old_location) and os.path.isdir(newpath):
                os.rename(old_location, new_location)
                logging.info("Moving %s to %s\n" % (old_location, new_location))
            else:
                logging.error("One of %s or %s does not exist\n" % (old_location, new_location))
    else:
        logging.error("%s is not a valid list\n" % trashlist)

# Function that checks paths are writable

项目：PowerSpikeGG 作者：PowerSpikeGG | 项目源码 | 文件源码

def _silent_connection_failure(func):
    """Decorator used to avoid raising an exception when the database timeouts

    Parameters:
        func: Function to decorate.
    """
    @wraps(func)
    def wrapper(*args, **kwargs):
        """Wraps the function to catch timeout exception.
        """
        if not FLAGS.disable_mongodb_exception:
            return func(*args, **kwargs)

        try:
            result = func(*args, **kwargs)
        except pymongo.errors.ServerSelectionTimeoutError as e:
            logging.error("Unable to reach the caching server: %s", e)
            return None
        return result

    return wrapper

项目：PyPlanet 作者：PyPlanet | 项目源码 | 文件源码

def _on_change(self, *args, **kwargs):
        # Making sure we set the settings + variables.
        if len(self._next_settings_update.keys()) > 0:
            logger.debug('Setting mode settings right now!')
            try:
                await self.update_settings(self._next_settings_update)
            except Exception as e:
                logging.error('Can\'t set the script mode settings! Error: {}'.format(str(e)))
            self._next_settings_update = dict()
        if len(self._next_variables_update.keys()) > 0:
            logger.debug('Setting mode variables right now!')
            try:
                await self.update_variables(self._next_variables_update)
            except Exception as e:
                logging.error('Can\'t set the script mode variables! Error: {}'.format(str(e)))
            self._next_variables_update = dict()

        # Make sure we send to the signal when mode is been changed.
        if self._current_script != self._next_script:
            await script_mode_changed.send_robust({
                'unloaded_script': self._current_script, 'loaded_script': self._next_script
            })

        await self.get_current_script(refresh=True)

项目：coursera-scheduled-exports 作者：LU-C4i | 项目源码 | 文件源码

def get_course_id(self):
        # Link below retrieves JSON file with course information based on course name
        base_url = "https://www.coursera.org/api/onDemandCourses.v1?q=slug&slug="
        # Paste
        url_tmp = base_url + self.course_slug
        # GET
        resp = requests.get(url_tmp)
        # If not ok
        if not resp.ok:
            # Log event
            if self.log:
                logging.error("Cannot fetch course id ({})".format(self.course_slug))
            raise ApiResolve("Server returned {}. Check whether course name is correct.".format(str(resp)))
        json_data = resp.json()
        # Get courseID
        course_id = json_data["elements"][0]["id"]
        # Return
        self.course_id = course_id

项目：django_pipedrive 作者：MasAval | 项目源码 | 文件源码

def sync_one(cls, external_id, last_error=None):
        post_data = cls.pipedrive_api_client.get_instance(external_id)

        # Error code from the API
        if not post_data[u'success']:
            logging.error(post_data)
            raise UnableToSyncException(cls, external_id)
        try:
            return cls.update_or_create_entity_from_api_post(post_data[u'data'])
        except IntegrityError as e:
            logging.warning(e)
            if e.message == last_error:
                raise SameErrorTwiceSyncException(cls, external_id, e.message)
            match = re.search('.*Key \((.*)\)=\((.*)\).*', e.message)
            if match:
                field_name = match.group(1)
                field_id = match.group(2)
                model = cls.field_model_map(field_name)
                model.sync_one(field_id)
                return cls.sync_one(external_id, e.message)
            else:
                raise Exception("Could not handle error message")

项目：apiTest 作者：wuranxu | 项目源码 | 文件源码

def transfer_data(self, case):
        try:
            params = self.addToken(case.get('params'))
            enable = case.get('enable')
            code = int(case.get('code'))
            headers = case.get('headers')
            expected = self.get_response(case.get('expected'))
            if params != '' and isinstance(params, str):
                params = self.form_to_dict(params) if 'form' in headers else dumps(self.data_to_json(params))
            else:
                params = dumps(params)
            headers = self.data_to_json(headers)
            case.update(dict(headers=headers, params=params,
                             enable=enable, code=code,
                             expected=expected))
        except Exception as err:
            logging.error("{} error: {}".format(Operator.get_current_func(), str(err)))
        return case