forked from LBRYCommunity/lbry-sdk
crudely fix loggly import problem
This commit is contained in:
parent
8d14fe6a90
commit
7ea88cfd22
1 changed files with 34 additions and 4 deletions
|
@ -3,11 +3,41 @@ import json
|
||||||
import logging
|
import logging
|
||||||
import logging.handlers
|
import logging.handlers
|
||||||
import sys
|
import sys
|
||||||
|
import traceback
|
||||||
import loggly.handlers
|
|
||||||
|
|
||||||
import lbrynet
|
import lbrynet
|
||||||
from lbrynet import conf
|
from lbrynet import conf
|
||||||
|
from requests_futures.sessions import FuturesSession
|
||||||
|
|
||||||
|
session = FuturesSession()
|
||||||
|
|
||||||
|
|
||||||
|
def bg_cb(sess, resp):
|
||||||
|
""" Don't do anything with the response """
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
class HTTPSHandler(logging.Handler):
|
||||||
|
def __init__(self, url, fqdn=False, localname=None, facility=None):
|
||||||
|
logging.Handler.__init__(self)
|
||||||
|
self.url = url
|
||||||
|
self.fqdn = fqdn
|
||||||
|
self.localname = localname
|
||||||
|
self.facility = facility
|
||||||
|
|
||||||
|
def get_full_message(self, record):
|
||||||
|
if record.exc_info:
|
||||||
|
return '\n'.join(traceback.format_exception(*record.exc_info))
|
||||||
|
else:
|
||||||
|
return record.getMessage()
|
||||||
|
|
||||||
|
def emit(self, record):
|
||||||
|
try:
|
||||||
|
payload = self.format(record)
|
||||||
|
session.post(self.url, data=payload, background_callback=bg_cb)
|
||||||
|
except (KeyboardInterrupt, SystemExit):
|
||||||
|
raise
|
||||||
|
except:
|
||||||
|
self.handleError(record)
|
||||||
|
|
||||||
|
|
||||||
DEFAULT_FORMAT = "%(asctime)s %(levelname)-8s %(name)s:%(lineno)d: %(message)s"
|
DEFAULT_FORMAT = "%(asctime)s %(levelname)-8s %(name)s:%(lineno)d: %(message)s"
|
||||||
|
@ -75,7 +105,7 @@ def configure_loggly_handler(url=None, **kwargs):
|
||||||
}
|
}
|
||||||
json_format.update(kwargs)
|
json_format.update(kwargs)
|
||||||
formatter = logging.Formatter(json.dumps(json_format))
|
formatter = logging.Formatter(json.dumps(json_format))
|
||||||
handler = loggly.handlers.HTTPSHandler(url)
|
handler = HTTPSHandler(url)
|
||||||
handler.setFormatter(formatter)
|
handler.setFormatter(formatter)
|
||||||
handler.name = 'loggly'
|
handler.name = 'loggly'
|
||||||
return handler
|
return handler
|
||||||
|
|
Loading…
Reference in a new issue