Python logging 模块,exception() 实例源码

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

项目:pykit    作者:baishancloud    | 项目源码 | 文件源码
def mem_check(opts):

    while True:

        if opts['gc']:
            try:
                gc.collect()
            except Exception as e:
                logging.exception(repr(e) + ' while gc.collect()')

        try:
            rss = psutil.Process(os.getpid()).memory_info().rss

            logging.info('current memory used: {rss}'.format(rss=rss))

            if rss > opts['threshold']:
                memory_dump(opts)
                os.abort()
        except Exception as e:
            logging.exception(repr(e) + ' while checking memory usage')

        finally:
            time.sleep(opts['interval'])
项目:rental    作者:meihuanyu    | 项目源码 | 文件源码
def runspider(name):
    configure_logging(install_root_handler=False)
    logging.basicConfig(
        filename='log/%s.log' % name,
        format='%(levelname)s %(asctime)s: %(message)s',
        level=logging.DEBUG
    )
    process = CrawlerProcess(get_project_settings())
    try:
        logging.info('runspider start spider:%s' % name)
        process.crawl(name)
        process.start()
    except Exception as e:
        logging.exception('runspider spider:%s exception:%s' % (name, e))

    logging.debug('finish this spider:%s\n\n' % name)
项目:marvin    作者:bassdread    | 项目源码 | 文件源码
def do(self, function_name, data):
        if function_name in dir(self.module):
            if self.debug is True:
                # this makes the plugin fail with stack trace in debug mode
                eval("self.module." + function_name)(data)
            else:
                # otherwise we log the exception and carry on
                try:
                    eval("self.module." + function_name)(data)
                except Exception:
                    logging.exception("problem in module {} {}".format(function_name, data))
        if "catch_all" in dir(self.module):
            if self.debug is True:
                # this makes the plugin fail with stack trace in debug mode
                self.module.catch_all(data)
            else:
                try:
                    self.module.catch_all(data)
                except Exception:
                    logging.exception("problem in catch all: {} {}".format(self.module, data))
项目:terraform-validator    作者:ApplauseOSS    | 项目源码 | 文件源码
def validate_rule(self, rule, resource):
        """
        Validate a single rule on the values of a resource by eval the boolean value of rule's expression.
        :param rule: rule dictionary
        :param resource: resource values dictionary
        :return: True if valid, otherwise False
        """
        try:
            if 'destroy' in resource and resource['destroy']:
                return True  # skip validation if resource is being destroyed
            R = ResourceContainer(resource)  # R is the identifier used in the rule expression
            return eval(rule["expr"])
        except Exception as e:
            '''exceptions are suppressed here to let the validation continue. So that the user will
            receive al complete report and be able to fix all errors at once.'''
            logging.exception('[EXCEPTION] Exception occurred during rule expression evaluation')
            return False
项目:PyPlanet    作者:PyPlanet    | 项目源码 | 文件源码
def destroy(self):
        """
        Destroy the Manialink with it's handlers and references.
        Will also hide the Manialink for all users!
        """
        try:
            SignalManager.get_signal('maniaplanet:manialink_answer').unregister(self.handle)
        except Exception as e:
            logging.exception(e)
        try:
            await self.manager.destroy(self)
        except:
            pass
        self.receivers = dict()
        self.data = None
        self.player_data = None
项目:PyPlanet    作者:PyPlanet    | 项目源码 | 文件源码
def destroy_sync(self):
        """
        Destroy the Manialink with it's handlers and references.
        Will also hide the Manialink for all users!

        This method is sync and will call a async method (destroying of the manialink at our players) async but will not
        be executed at the same time. Be aware with this one!
        """
        try:
            SignalManager.get_signal('maniaplanet:manialink_answer').unregister(self.handle)
            asyncio.ensure_future(self.manager.destroy(self))
        except Exception as e:
            logging.exception(e)
        self.receivers = dict()
        self.data = None
        self.player_data = None
项目:PyPlanet    作者:PyPlanet    | 项目源码 | 文件源码
def get_player(self, login=None, pk=None, lock=True):
        """
        Get player by login or primary key.

        :param login: Login.
        :param pk: Primary Key identifier.
        :param lock: Lock for a sec when receiving.
        :return: Player or exception if not found
        :rtype: pyplanet.apps.core.maniaplanet.models.Player
        """
        try:
            if login:
                return await Player.get_by_login(login)
            elif pk:
                return await Player.get(pk=pk)
            else:
                raise PlayerNotFound('Player not found.')
        except DoesNotExist:
            if lock:
                await asyncio.sleep(4)
                return await self.get_player(login=login, pk=pk, lock=False)
            else:
                raise PlayerNotFound('Player not found.')
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_setup(self, seqid, iprot, oprot):
        args = setup_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = setup_result()
        try:
            self._handler.setup(args.name, args.description)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("setup", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_addService(self, seqid, iprot, oprot):
        args = addService_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = addService_result()
        try:
            self._handler.addService(args.svc)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("addService", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_removeService(self, seqid, iprot, oprot):
        args = removeService_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = removeService_result()
        try:
            self._handler.removeService(args.svc)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("removeService", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_initConsumer(self, seqid, iprot, oprot):
        args = initConsumer_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = initConsumer_result()
        try:
            self._handler.initConsumer(args.scheme, args.hostname, args.port, args.urlPrefix, args.clientID, args.hceCard, args.pspConfig)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("initConsumer", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_initProducer(self, seqid, iprot, oprot):
        args = initProducer_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = initProducer_result()
        try:
            self._handler.initProducer(args.pspConfig)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("initProducer", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_startServiceBroadcast(self, seqid, iprot, oprot):
        args = startServiceBroadcast_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = startServiceBroadcast_result()
        try:
            self._handler.startServiceBroadcast(args.timeoutMillis)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("startServiceBroadcast", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_stopServiceBroadcast(self, seqid, iprot, oprot):
        args = stopServiceBroadcast_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = stopServiceBroadcast_result()
        try:
            self._handler.stopServiceBroadcast()
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("stopServiceBroadcast", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_deviceDiscovery(self, seqid, iprot, oprot):
        args = deviceDiscovery_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = deviceDiscovery_result()
        try:
            result.success = self._handler.deviceDiscovery(args.timeoutMillis)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("deviceDiscovery", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_searchForDevice(self, seqid, iprot, oprot):
        args = searchForDevice_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = searchForDevice_result()
        try:
            result.success = self._handler.searchForDevice(args.timeoutMillis, args.deviceName)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("searchForDevice", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_requestServices(self, seqid, iprot, oprot):
        args = requestServices_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = requestServices_result()
        try:
            result.success = self._handler.requestServices()
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("requestServices", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_selectService(self, seqid, iprot, oprot):
        args = selectService_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = selectService_result()
        try:
            result.success = self._handler.selectService(args.serviceId, args.numberOfUnits, args.priceId)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("selectService", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_makePayment(self, seqid, iprot, oprot):
        args = makePayment_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = makePayment_result()
        try:
            result.success = self._handler.makePayment(args.request)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("makePayment", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_beginServiceDelivery(self, seqid, iprot, oprot):
        args = beginServiceDelivery_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = beginServiceDelivery_result()
        try:
            result.success = self._handler.beginServiceDelivery(args.serviceID, args.serviceDeliveryToken, args.unitsToSupply)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("beginServiceDelivery", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_endServiceDelivery(self, seqid, iprot, oprot):
        args = endServiceDelivery_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = endServiceDelivery_result()
        try:
            result.success = self._handler.endServiceDelivery(args.serviceID, args.serviceDeliveryToken, args.unitsReceived)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("endServiceDelivery", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_CloseRPCAgent(self, seqid, iprot, oprot):
        args = CloseRPCAgent_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = CloseRPCAgent_result()
        try:
            self._handler.CloseRPCAgent()
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("CloseRPCAgent", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()

# HELPER FUNCTIONS AND STRUCTURES
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_endServiceDelivery(self, seqid, iprot, oprot):
        args = endServiceDelivery_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = endServiceDelivery_result()
        try:
            self._handler.endServiceDelivery(args.serviceID, args.serviceDeliveryToken, args.unitsReceived)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("endServiceDelivery", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_makePaymentEvent(self, seqid, iprot, oprot):
        args = makePaymentEvent_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = makePaymentEvent_result()
        try:
            self._handler.makePaymentEvent(args.totalPrice, args.orderCurrency, args.clientToken, args.orderDescription, args.uuid)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("makePaymentEvent", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_serviceDiscoveryEvent(self, seqid, iprot, oprot):
        args = serviceDiscoveryEvent_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = serviceDiscoveryEvent_result()
        try:
            self._handler.serviceDiscoveryEvent(args.remoteAddr)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("serviceDiscoveryEvent", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_servicePricesEvent(self, seqid, iprot, oprot):
        args = servicePricesEvent_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = servicePricesEvent_result()
        try:
            self._handler.servicePricesEvent(args.remoteAddr, args.serviceId)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("servicePricesEvent", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:wpw-sdk-python    作者:WPTechInnovation    | 项目源码 | 文件源码
def process_serviceTotalPriceEvent(self, seqid, iprot, oprot):
        args = serviceTotalPriceEvent_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = serviceTotalPriceEvent_result()
        try:
            self._handler.serviceTotalPriceEvent(args.remoteAddr, args.serviceID, args.totalPriceResp)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("serviceTotalPriceEvent", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()
项目:mblog    作者:moling3650    | 项目源码 | 文件源码
def find_by_cookie(cls, cookie_str):
        if not cookie_str:
            return None
        try:
            L = cookie_str.split('-')
            if len(L) != 3:
                return None
            uid, expires, sha1 = L
            if int(expires) < time.time():
                return None
            user = await cls.find(uid)
            if not user:
                return None
            s = '%s-%s-%s-%s' % (uid, user.get('password'), expires, COOKIE_KEY)
            if sha1 != hashlib.sha1(s.encode('utf-8')).hexdigest():
                logging.info('invalid sha1')
                return None
            user.password = '******'
            return user
        except Exception as e:
            logging.exception(e)
            return None


# ?????
项目:grow-ext-kintaro    作者:grow    | 项目源码 | 文件源码
def execute(self, kintaro, force=False):
        try:
            project = kintaro.projects().rpcGetProject(body={
                'project_id': self.project_id,
            }).execute()
        except errors.HttpError as e:
            logging.exception('Error fetching -> {}'.format(self))
            return
        self.modified_by = project['mod_info'].get('updated_by')
        self.modified = datetime.datetime.fromtimestamp(
                int(project['mod_info']['updated_on_millis']) / 1000.0)
        if force or self.last_run is None or self.modified > self.last_run:
            if self.webhook_url:
                self.run_webhook(project)
            else:
                logging.info('Skipping (no webhook) -> {}'.format(self))
        else:
            logging.info('Skipping (up-to-date) -> {}'.format(self))
        self.last_run = datetime.datetime.now()
        self.put()
项目:oscars2016    作者:0x0ece    | 项目源码 | 文件源码
def __init__(self, request=None, response=None):
        """Calls the constructor of the super and does the local setup."""
        super(InitHandler, self).__init__(request, response)
        self.client = pubsub_utils.get_client()
        # self._setup_topic()
        self._setup_subscription()

    # def _setup_topic(self):
    #     """Creates a topic if it does not exist."""
    #     topic_name = pubsub_utils.get_full_topic_name()
    #     try:
    #         self.client.projects().topics().get(
    #             topic=topic_name).execute()
    #     except errors.HttpError as e:
    #         if e.resp.status == 404:
    #             self.client.projects().topics().create(
    #                 name=topic_name, body={}).execute()
    #         else:
    #             logging.exception(e)
    #             raise
项目:oscars2016    作者:0x0ece    | 项目源码 | 文件源码
def _setup_subscription(self):
        """Creates a subscription if it does not exist."""
        subscription_name = pubsub_utils.get_full_subscription_name()
        try:
            self.client.projects().subscriptions().get(
                subscription=subscription_name).execute()
        except errors.HttpError as e:
            if e.resp.status == 404:
                body = {
                    'topic': pubsub_utils.get_full_topic_name(),
                    'pushConfig': {
                        'pushEndpoint': pubsub_utils.get_app_endpoint_url()
                    }
                }
                self.client.projects().subscriptions().create(
                    name=subscription_name, body=body).execute()
            else:
                logging.exception(e)
                raise
项目:hearthscan-bot    作者:d-schmidt    | 项目源码 | 文件源码
def main():
    print("see log scrape.log")
    if os.path.isfile("scrape.log"):
        os.remove("scrape.log")
    log.basicConfig(filename="scrape.log",
            format='%(asctime)s %(levelname)s %(message)s',
            level=log.DEBUG)

    try:
        log.debug("main() full scrape will take 5-10 minutes")
        cards, tokens = loadJsonCards()

        saveCardsAsJson("data/cards.json", loadSets(allcards=cards))

        # a lot of token names are not unique
        # a static, handmade list of ids is more reliable
        if os.path.isfile('data/tokenlist.json'):
            with open('data/tokenlist.json', 'r', encoding='utf8') as f:
                saveCardsAsJson("data/tokens.json", loadTokens(tokens, json.load(f)))
    except Exception as e:
        log.exception("main() error %s", e)
项目:os-xenapi    作者:openstack    | 项目源码 | 文件源码
def _resume_compute(session, compute_ref, compute_uuid):
    """Resume compute node on slave host after pool join.

    This has to happen regardless of the success or failure of the join
    operation.
    """
    try:
        # session is valid if the join operation has failed
        session.xenapi.VM.start(compute_ref, False, True)
    except XenAPI.Failure:
        # if session is invalid, e.g. xapi has restarted, then the pool
        # join has been successful, wait for xapi to become alive again
        for c in range(0, DEFAULT_TRIES):
            try:
                _run_command(["xe", "vm-start", "uuid=%s" % compute_uuid])
                return
            except pluginlib.PluginError:
                logging.exception('Waited %d seconds for the slave to '
                                  'become available.' % (c * DEFAULT_SLEEP))
                time.sleep(DEFAULT_SLEEP)
        raise pluginlib.PluginError('Unrecoverable error: the host has '
                                    'not come back for more than %d seconds'
                                    % (DEFAULT_SLEEP * (DEFAULT_TRIES + 1)))
项目:spacy-nlp-docker    作者:pasupulaphani    | 项目源码 | 文件源码
def process_tag(self, seqid, iprot, oprot):
    args = tag_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = tag_result()
    try:
      result.success = self._handler.tag(args.sentence)
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("tag", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()


# HELPER FUNCTIONS AND STRUCTURES
项目:spacy-nlp-docker    作者:pasupulaphani    | 项目源码 | 文件源码
def process_tag(self, seqid, iprot, oprot):
    args = tag_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = tag_result()
    try:
      result.success = self._handler.tag(args.sentence)
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("tag", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()


# HELPER FUNCTIONS AND STRUCTURES
项目:pylogging    作者:ansrivas    | 项目源码 | 文件源码
def __init__(self, app_name, elastic_url, headers=None, auth=None):
        """Initialize the ElasticLoggger class.

        Args:
            app_name (str)    :Name of the application which is using current logger
            elastic_url (str) :Url of elastic-http-input to push logs to (for eg. 'http://localhost:3332' )
            headers (str)     :Since this is post request headers are required, defaults to {'content-type': 'application/json'}
            auth (tuple)      :A tuple containing username and password: for eg.  ('myuser', 'mypassword')
        """
        self.elastic_url = elastic_url
        self.auth = auth
        self.headers = headers
        if not self.headers:
            self.headers = {'content-type': 'application/json'}

        self.debug_method = partial(self.__log, level='debug')
        self.error_method = partial(self.__log, level='error')
        self.info_method = partial(self.__log, level='info')
        self.exception_method = partial(self.__log, level='exception')
        self.session = FuturesSession(max_workers=10)
        self.app_name = app_name
项目:n1mm_view    作者:n1kdo    | 项目源码 | 文件源码
def update_charts(q, event, size):
    try:
        os.nice(10)
    except AttributeError:
        logging.warn("can't be nice to windows")
    q.put((CRAWL_MESSAGE, 4, 'Chart engine starting...'))
    base_map = graphics.create_map()
    last_qso_timestamp = 0
    q.put((CRAWL_MESSAGE, 4, ''))

    try:
        while not event.is_set():
            t0 = time.time()
            last_qso_timestamp = load_data(size, q, base_map, last_qso_timestamp)
            t1 = time.time()
            delta = t1 - t0
            update_delay = config.DATA_DWELL_TIME - delta
            if update_delay < 0:
                update_delay = config.DATA_DWELL_TIME
            logging.debug('Next data update in %f seconds', update_delay)
            event.wait(update_delay)
    except Exception, e:
        logging.exception('Exception in update_charts', exc_info=e)
        q.put((CRAWL_MESSAGE, 4, 'Chart engine failed.', graphics.YELLOW, graphics.RED))
项目:n1mm_view    作者:n1kdo    | 项目源码 | 文件源码
def delete_contact(db, cursor, timestamp, station, callsign):
    """
    Delete the results of a delete in N1MM
    """

    """ station_id = stations.lookup_station_id(station)
"""

    logging.info('DELETEQSO: %s, timestamp = %s' % (callsign, calendar.timegm(timestamp)))
    try:
        cursor.execute(
            "delete from qso_log where callsign = ? and timestamp = ?", (callsign, calendar.timegm(timestamp),))
        db.commit()
    except Exception as e:
        logging.exception('Exception deleting contact from db.')
        return ''
项目:sndlatr    作者:Schibum    | 项目源码 | 文件源码
def open_resource(name):
    """Load the object from the datastore"""
    import logging
    from cStringIO import StringIO
    try:
        data = ndb.Key('Zoneinfo', name, namespace=NDB_NAMESPACE).get().data
    except AttributeError:
        # Missing zone info; test for GMT - which would be there if the 
        # Zoneinfo has been initialized.
        if ndb.Key('Zoneinfo', 'GMT', namespace=NDB_NAMESPACE).get():
          # the user asked for a zone that doesn't seem to exist.
          logging.exception("Requested zone '%s' is not in the database." %
              name)
          raise

        # we need to initialize the database
        init_zoneinfo()
        return open_resource(name)

    return StringIO(data)
项目:rental    作者:meihuanyu    | 项目源码 | 文件源码
def select_proxy(self, table_name, **kwargs):
        filter = {}
        for k, v in kwargs.items():
            if v != '':
                filter[k] = v

        try:
            command = "SELECT * FROM {name} WHERE anonymity LIKE '{anonymity}' AND https LIKE '{https}' ORDER BY " \
                      "{order} {sort} limit {count}". \
                format(name=table_name, anonymity=filter.get('anonymity', '%'),
                       https=filter.get('https', '%'), order=filter.get('order', 'save_time'),
                       sort=filter.get('sort', 'desc'), count=filter.get('count', 100))

            result = self.query(command)
            data = [{
                'ip': item[1], 'port': item[2], 'anonymity': item[4], 'https': item[5],
                'speed': item[6], 'save_time': str(item[8])
            } for item in result]
            return data
        except Exception as e:
            logging.exception('mysql select_proxy exception msg:%s' % e)
        return []
项目:Tktr    作者:Intuity    | 项目源码 | 文件源码
def refund_stripe_charge (self, charge_id):
        all_methods = PROP.getProperty(self.request, PROP.PAYMENT_METHODS)
        method = [x for x in all_methods if x.__name__ == "stripe"]
        method = method[0] if len(method) > 0 else None
        if method == None:
            logging.exception(self.user.username + ": Could not refund %s because could not find stripe payment method" % charge_id)
            return False
        priv_api_key = method.settings[PROP.STRIPE_API_KEY].value
        try:
            stripe.api_key = priv_api_key
            refund = stripe.Refund.create(
                charge=charge_id,
                reason="duplicate"
            )
            if refund != None and "id" in refund:
                logging.info(self.user.username + ": Refunded charge %s with refund id %s" % (charge_id, refund["id"]))
                return True
            else:
                logging.error(self.user.username + ": Refund of charge %s may have failed" % charge_id)
                return False
        except Exception, e:
            logging.error(self.user.username + ": Exception was thrown during refund: %s" % e)
            return False
项目:zinc    作者:PressLabs    | 项目源码 | 文件源码
def commit(self, preserve_cache=False):
        if not preserve_cache:
            self._clear_cache()
        if not self._change_batch:
            return

        try:
            self._client.change_resource_record_sets(
                HostedZoneId=self.id,
                ChangeBatch={'Changes': self._change_batch}
            )
        except ClientError as excp:
            if excp.response['Error']['Code'] == 'InvalidInput':
                logging.exception("failed to process batch %r", self._change_batch)
            raise
        self._reset_change_batch()
项目:zinc    作者:PressLabs    | 项目源码 | 文件源码
def _reconcile_policy_records(self):
        """
        Reconcile policy records for this zone.
        """
        with self.db_zone.lock_dirty_policy_records() as dirty_policy_records:
            dirty_policies = set()
            for policy_record in dirty_policy_records:
                if not policy_record.deleted:
                    dirty_policies.add(policy_record.policy)
            for policy in dirty_policies:
                r53_policy = Policy(policy=policy, zone=self)
                r53_policy.reconcile()
                self.commit(preserve_cache=True)
            for policy_record in dirty_policy_records:
                try:
                    with transaction.atomic():
                        policy_record.r53_policy_record.reconcile()
                        self.commit(preserve_cache=True)
                except ClientError as excp:
                    logger.exception("failed to reconcile record %r", policy_record)
                    self._reset_change_batch()
            self._delete_orphaned_managed_records()
            self.commit()
项目:LoLVRSpectate    作者:Fire-Proof    | 项目源码 | 文件源码
def run(self, *args, **kwargs):
        try:
            self.spectate = VRSpectate()
            self.spectate.run()
        except ProcessException as e:
            logging.exception(e)
            if "get pid from name" in str(e):
                self.error.emit("LoL client was not found")
            elif "ReadProcessMemory" in str(e):
                self.error.emit("Either the LoL client or this program is outdated")
            else:
                self.error.emit(str(e))
        except pywintypes.error as e:
            logging.exception(e)
            if "SetSecurityInfo" in str(e):
                self.error.emit("Unable to access the League of Legends client, you have to run LoLVRSpectate at the "
                                "same privilege level as the LoL client. \nEX. if the LoL client is running as admin "
                                "LoLVRSpectate also has to run as admin")
        except Exception as e:
            logging.exception(e)
            self.error.emit("Unknown error, please submit a bug report at https://github.com/Fire-Proof/LoLVRSpectate "
                            "(please include the LoLVRSpectate.log file)")
项目:z3    作者:PressLabs    | 项目源码 | 文件源码
def main_loop(self, concurrency=4, worker_class=UploadWorker):
        chunk_index = 0
        self._begin_upload()
        self._workers = self._start_workers(concurrency, worker_class=worker_class)
        while self._pending_chunks or not self.stream_handler.finished:
            self._check_workers()  # raise exception and stop everything if any worker has crashed
            # print "main_loop p:{} o:{} i:{}".format(
            #     self._pending_chunks, self.outbox.qsize(), self.inbox.qsize())
            # consume results first as this is a quick operation
            self._handle_results()
            chunk = self.stream_handler.get_chunk()
            if chunk:
                # s3 multipart index is 1 based, increment before sending
                chunk_index += 1
                self._send_chunk(chunk_index, chunk)
        self._finish_upload()
        self.results.sort()
        return multipart_etag(r[1] for r in self.results)
项目:mongodb_consistent_backup    作者:Percona-Lab    | 项目源码 | 文件源码
def wait(self):
        try:
            while self._process.stderr:
                poll = select([self._process.stderr.fileno()], [], [])
                if len(poll) >= 1:
                    for fd in poll[0]:
                        read = self._process.stderr.readline()
                        line = self.parse_mongodump_line(read)
                        if not line:
                            continue
                        elif self.is_password_prompt(read):
                            self.handle_password_prompt()
                        elif self.is_failed_line(read):
                            self.handle_failure(read)
                            break
                        else:
                            logging.info(line)
                if self._process.poll() is not None:
                    break
        except Exception, e:
            logging.exception("Error reading mongodump output: %s" % e)
        finally:
            self._process.communicate()
项目:dragonchain    作者:dragonchain    | 项目源码 | 文件源码
def process_ping(self, seqid, iprot, oprot):
    args = ping_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = ping_result()
    try:
      self._handler.ping()
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("ping", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()
项目:dragonchain    作者:dragonchain    | 项目源码 | 文件源码
def process_get_node_info(self, seqid, iprot, oprot):
    args = get_node_info_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = get_node_info_result()
    try:
      result.success = self._handler.get_node_info()
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except UnauthorizedException as unauthorized:
      msg_type = TMessageType.REPLY
      result.unauthorized = unauthorized
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("get_node_info", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()
项目:dragonchain    作者:dragonchain    | 项目源码 | 文件源码
def process_register_node(self, seqid, iprot, oprot):
    args = register_node_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = register_node_result()
    try:
      result.success = self._handler.register_node(args.node, args.pass_phrase)
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except UnauthorizedException as unauthorized:
      msg_type = TMessageType.REPLY
      result.unauthorized = unauthorized
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("register_node", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()
项目:dragonchain    作者:dragonchain    | 项目源码 | 文件源码
def process_phase_1_message(self, seqid, iprot, oprot):
    args = phase_1_message_args()
    args.read(iprot)
    iprot.readMessageEnd()
    result = phase_1_message_result()
    try:
      result.success = self._handler.phase_1_message(args.p1)
      msg_type = TMessageType.REPLY
    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
      raise
    except Exception as ex:
      msg_type = TMessageType.EXCEPTION
      logging.exception(ex)
      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
    oprot.writeMessageBegin("phase_1_message", msg_type, seqid)
    result.write(oprot)
    oprot.writeMessageEnd()
    oprot.trans.flush()