220 lines
7.6 KiB
Python
220 lines
7.6 KiB
Python
from sanic.defaultFilter import DefaultFilter
|
|
import os
|
|
import sys
|
|
import syslog
|
|
import platform
|
|
import types
|
|
|
|
SANIC_PREFIX = 'SANIC_'
|
|
|
|
_address_dict = {
|
|
'Windows': ('localhost', 514),
|
|
'Darwin': '/var/run/syslog',
|
|
'Linux': '/dev/log',
|
|
'FreeBSD': '/dev/log'
|
|
}
|
|
|
|
LOGGING = {
|
|
'version': 1,
|
|
'filters': {
|
|
'accessFilter': {
|
|
'()': DefaultFilter,
|
|
'param': [0, 10, 20]
|
|
},
|
|
'errorFilter': {
|
|
'()': DefaultFilter,
|
|
'param': [30, 40, 50]
|
|
}
|
|
},
|
|
'formatters': {
|
|
'simple': {
|
|
'format': '%(asctime)s - (%(name)s)[%(levelname)s]: %(message)s',
|
|
'datefmt': '%Y-%m-%d %H:%M:%S'
|
|
},
|
|
'access': {
|
|
'format': '%(asctime)s - (%(name)s)[%(levelname)s][%(host)s]: ' +
|
|
'%(request)s %(message)s %(status)d %(byte)d',
|
|
'datefmt': '%Y-%m-%d %H:%M:%S'
|
|
}
|
|
},
|
|
'handlers': {
|
|
'internal': {
|
|
'class': 'logging.StreamHandler',
|
|
'filters': ['accessFilter'],
|
|
'formatter': 'simple',
|
|
'stream': sys.stderr
|
|
},
|
|
'accessStream': {
|
|
'class': 'logging.StreamHandler',
|
|
'filters': ['accessFilter'],
|
|
'formatter': 'access',
|
|
'stream': sys.stderr
|
|
},
|
|
'errorStream': {
|
|
'class': 'logging.StreamHandler',
|
|
'filters': ['errorFilter'],
|
|
'formatter': 'simple',
|
|
'stream': sys.stderr
|
|
},
|
|
# before you use accessSysLog, be sure that log levels
|
|
# 0, 10, 20 have been enabled in you syslog configuration
|
|
# otherwise you won't be able to see the output in syslog
|
|
# logging file.
|
|
'accessSysLog': {
|
|
'class': 'logging.handlers.SysLogHandler',
|
|
'address': _address_dict.get(platform.system(),
|
|
('localhost', 514)),
|
|
'facility': syslog.LOG_DAEMON,
|
|
'filters': ['accessFilter'],
|
|
'formatter': 'access'
|
|
},
|
|
'errorSysLog': {
|
|
'class': 'logging.handlers.SysLogHandler',
|
|
'address': _address_dict.get(platform.system(),
|
|
('localhost', 514)),
|
|
'facility': syslog.LOG_DAEMON,
|
|
'filters': ['errorFilter'],
|
|
'formatter': 'simple'
|
|
},
|
|
'accessTimedRotatingFile': {
|
|
'class': 'logging.handlers.TimedRotatingFileHandler',
|
|
'filters': ['accessFilter'],
|
|
'formatter': 'access',
|
|
'when': 'D',
|
|
'interval': 1,
|
|
'backupCount': 7,
|
|
'filename': 'access.log'
|
|
},
|
|
'errorTimedRotatingFile': {
|
|
'class': 'logging.handlers.TimedRotatingFileHandler',
|
|
'filters': ['errorFilter'],
|
|
'when': 'D',
|
|
'interval': 1,
|
|
'backupCount': 7,
|
|
'filename': 'error.log',
|
|
'formatter': 'simple'
|
|
}
|
|
},
|
|
'loggers': {
|
|
'sanic': {
|
|
'level': 'DEBUG',
|
|
'handlers': ['internal', 'errorStream']
|
|
},
|
|
'network': {
|
|
'level': 'DEBUG',
|
|
'handlers': ['accessStream', 'errorStream']
|
|
}
|
|
}
|
|
}
|
|
|
|
# this happens when using container or systems without syslog
|
|
# keep things in config would cause file not exists error
|
|
_addr = LOGGING['handlers']['accessSysLog']['address']
|
|
if type(_addr) is str and not os.path.exists(_addr):
|
|
LOGGING['handlers'].pop('accessSysLog')
|
|
LOGGING['handlers'].pop('errorSysLog')
|
|
|
|
|
|
class Config(dict):
|
|
def __init__(self, defaults=None, load_env=True, keep_alive=True):
|
|
super().__init__(defaults or {})
|
|
self.LOGO = """
|
|
▄▄▄▄▄
|
|
▀▀▀██████▄▄▄ _______________
|
|
▄▄▄▄▄ █████████▄ / \\
|
|
▀▀▀▀█████▌ ▀▐▄ ▀▐█ | Gotta go fast! |
|
|
▀▀█████▄▄ ▀██████▄██ | _________________/
|
|
▀▄▄▄▄▄ ▀▀█▄▀█════█▀ |/
|
|
▀▀▀▄ ▀▀███ ▀ ▄▄
|
|
▄███▀▀██▄████████▄ ▄▀▀▀▀▀▀█▌
|
|
██▀▄▄▄██▀▄███▀ ▀▀████ ▄██
|
|
▄▀▀▀▄██▄▀▀▌████▒▒▒▒▒▒███ ▌▄▄▀
|
|
▌ ▐▀████▐███▒▒▒▒▒▐██▌
|
|
▀▄▄▄▄▀ ▀▀████▒▒▒▒▄██▀
|
|
▀▀█████████▀
|
|
▄▄██▀██████▀█
|
|
▄██▀ ▀▀▀ █
|
|
▄█ ▐▌
|
|
▄▄▄▄█▌ ▀█▄▄▄▄▀▀▄
|
|
▌ ▐ ▀▀▄▄▄▀
|
|
▀▀▄▄▀
|
|
"""
|
|
self.REQUEST_MAX_SIZE = 100000000 # 100 megababies
|
|
self.REQUEST_TIMEOUT = 60 # 60 seconds
|
|
self.KEEP_ALIVE = keep_alive
|
|
|
|
if load_env:
|
|
self.load_environment_vars()
|
|
|
|
def __getattr__(self, attr):
|
|
try:
|
|
return self[attr]
|
|
except KeyError as ke:
|
|
raise AttributeError("Config has no '{}'".format(ke.args[0]))
|
|
|
|
def __setattr__(self, attr, value):
|
|
self[attr] = value
|
|
|
|
def from_envvar(self, variable_name):
|
|
"""Load a configuration from an environment variable pointing to
|
|
a configuration file.
|
|
|
|
:param variable_name: name of the environment variable
|
|
:return: bool. ``True`` if able to load config, ``False`` otherwise.
|
|
"""
|
|
config_file = os.environ.get(variable_name)
|
|
if not config_file:
|
|
raise RuntimeError('The environment variable %r is not set and '
|
|
'thus configuration could not be loaded.' %
|
|
variable_name)
|
|
return self.from_pyfile(config_file)
|
|
|
|
def from_pyfile(self, filename):
|
|
"""Update the values in the config from a Python file.
|
|
Only the uppercase variables in that module are stored in the config.
|
|
|
|
:param filename: an absolute path to the config file
|
|
"""
|
|
module = types.ModuleType('config')
|
|
module.__file__ = filename
|
|
try:
|
|
with open(filename) as config_file:
|
|
exec(compile(config_file.read(), filename, 'exec'),
|
|
module.__dict__)
|
|
except IOError as e:
|
|
e.strerror = 'Unable to load configuration file (%s)' % e.strerror
|
|
raise
|
|
self.from_object(module)
|
|
return True
|
|
|
|
def from_object(self, obj):
|
|
"""Update the values from the given object.
|
|
Objects are usually either modules or classes.
|
|
|
|
Just the uppercase variables in that object are stored in the config.
|
|
Example usage::
|
|
|
|
from yourapplication import default_config
|
|
app.config.from_object(default_config)
|
|
|
|
You should not use this function to load the actual configuration but
|
|
rather configuration defaults. The actual config should be loaded
|
|
with :meth:`from_pyfile` and ideally from a location not within the
|
|
package because the package might be installed system wide.
|
|
|
|
:param obj: an object holding the configuration
|
|
"""
|
|
for key in dir(obj):
|
|
if key.isupper():
|
|
self[key] = getattr(obj, key)
|
|
|
|
def load_environment_vars(self):
|
|
"""
|
|
Looks for any SANIC_ prefixed environment variables and applies
|
|
them to the configuration if present.
|
|
"""
|
|
for k, v in os.environ.items():
|
|
if k.startswith(SANIC_PREFIX):
|
|
_, config_key = k.split(SANIC_PREFIX, 1)
|
|
self[config_key] = v
|