KevinMidboe/transatlanticTorrentExpress
1
0
Fork 0
mirror of https://github.com/KevinMidboe/transatlanticTorrentExpress.git synced 2025-10-29 09:50:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make elastic logging optional with config flag

Browse Source
This commit is contained in:
Kevin
2023-08-25 19:30:50 +02:00
parent 948eeb1d31
commit ed2a1d9a53
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
logger.py
View File

@@ -74,7 +74,7 @@ class ESHandler(logging.Handler):
return response return response
except urllib.error.HTTPError as e: except urllib.error.HTTPError as e:
print('Unable to reach elastic, error:', e) print('Unable to reach elastic, error:', e)
return asdf return
class ElasticFieldParameterAdapter(logging.LoggerAdapter): class ElasticFieldParameterAdapter(logging.LoggerAdapter):
def __init__(self, logger, extra={}): def __init__(self, logger, extra={}):
@@ -93,12 +93,15 @@ esHost = config['ELASTIC']['host']
esPort = config['ELASTIC']['port'] esPort = config['ELASTIC']['port']
esSSL = config['ELASTIC']['ssl'] esSSL = config['ELASTIC']['ssl']
esApiKey = config['ELASTIC']['api_key'] esApiKey = config['ELASTIC']['api_key']
eh = ESHandler(host=esHost, port=esPort, ssl=esSSL, apiKey=esApiKey) esEnabled = config['ELASTIC']['enabled']
eh.setLevel(logging.DEBUG) if esEnabled == 'True':
eh = ESHandler(host=esHost, port=esPort, ssl=esSSL, apiKey=esApiKey)
eh.setLevel(logging.DEBUG)
formatter = logging.Formatter('%(asctime)s %(levelname)8s | %(message)s') formatter = logging.Formatter('%(asctime)s %(levelname)8s | %(message)s')
fh.setFormatter(formatter) fh.setFormatter(formatter)
logger.addHandler(fh) logger.addHandler(fh)
logger.addHandler(ch) logger.addHandler(ch)
logger.addHandler(eh) if esEnabled == 'True':
logger.addHandler(eh)
logger = ElasticFieldParameterAdapter(logger) logger = ElasticFieldParameterAdapter(logger)