mirror of
https://github.com/house-of-vanity/OutFleet.git
synced 2025-08-21 14:37:16 +00:00
fix logging
This commit is contained in:
committed by
GitHub
parent
58be345610
commit
b01d86251c
27
main.py
27
main.py
@@ -16,6 +16,22 @@ from flask_cors import CORS
|
|||||||
from werkzeug.routing import BaseConverter
|
from werkzeug.routing import BaseConverter
|
||||||
from lib import Server, write_config, get_config, args, lock
|
from lib import Server, write_config, get_config, args, lock
|
||||||
|
|
||||||
|
class DuplicateFilter(logging.Filter):
|
||||||
|
def __init__(self, interval=100):
|
||||||
|
super(DuplicateFilter, self).__init__()
|
||||||
|
self.msgs = {}
|
||||||
|
self.interval = interval
|
||||||
|
|
||||||
|
def filter(self, record):
|
||||||
|
msg = record.getMessage()
|
||||||
|
if msg not in self.msgs:
|
||||||
|
self.msgs[msg] = 0
|
||||||
|
self.msgs[msg] += 1
|
||||||
|
|
||||||
|
# Print every nth message, where n is the interval
|
||||||
|
if self.msgs[msg] % self.interval == 0:
|
||||||
|
return True
|
||||||
|
return False
|
||||||
|
|
||||||
logging.getLogger("werkzeug").setLevel(logging.ERROR)
|
logging.getLogger("werkzeug").setLevel(logging.ERROR)
|
||||||
|
|
||||||
@@ -25,15 +41,6 @@ logging.basicConfig(
|
|||||||
datefmt="%d-%m-%Y %H:%M:%S",
|
datefmt="%d-%m-%Y %H:%M:%S",
|
||||||
)
|
)
|
||||||
|
|
||||||
app = Flask(__name__)
|
|
||||||
|
|
||||||
class RegexConverter(BaseConverter):
|
|
||||||
def __init__(self, url_map, *items):
|
|
||||||
super(RegexConverter, self).__init__(url_map)
|
|
||||||
self.regex = items[0]
|
|
||||||
|
|
||||||
app.url_map.converters['regex'] = RegexConverter
|
|
||||||
|
|
||||||
log = logging.getLogger("OutFleet")
|
log = logging.getLogger("OutFleet")
|
||||||
file_handler = logging.FileHandler("sync.log")
|
file_handler = logging.FileHandler("sync.log")
|
||||||
formatter = logging.Formatter(
|
formatter = logging.Formatter(
|
||||||
@@ -41,6 +48,8 @@ formatter = logging.Formatter(
|
|||||||
)
|
)
|
||||||
file_handler.setFormatter(formatter)
|
file_handler.setFormatter(formatter)
|
||||||
log.addHandler(file_handler)
|
log.addHandler(file_handler)
|
||||||
|
duplicate_filter = DuplicateFilter(interval=100)
|
||||||
|
log.addFilter(duplicate_filter)
|
||||||
|
|
||||||
CFG_PATH = args.config
|
CFG_PATH = args.config
|
||||||
NAMESPACE = k8s.NAMESPACE
|
NAMESPACE = k8s.NAMESPACE
|
||||||
|
Reference in New Issue
Block a user