import importlib.util
import inspect
import logging
import os
import types
from importlib import import_module
from pprint import pformat
from pydoc import locate
import tornado.log
from tornado.ioloop import IOLoop
from tornado.web import Application
from biothings.utils.web.userquery import ESUserQuery
from biothings.web.handlers import BaseAPIHandler, BaseESRequestHandler
from biothings.web.options import OptionsManager as OptionSets
from biothings.web.utils import DevInfo, FieldNote
from . import default as web_default
from .data import DataConnections, DataMetadata, DataPipeline
try:
from raven.contrib.tornado import AsyncSentryClient
except ImportError:
__SENTRY_INSTALLED__ = False
else:
__SENTRY_INSTALLED__ = True
class BiothingConfigError(Exception):
pass
[docs]class BiothingWebSettings():
'''
A container for the settings that configure the web API.
* Environment variables can override settings of the same names.
* Default values are defined in biothings.web.settings.default.
'''
_default = object()
_parent = object()
_user = object()
def __init__(self, config=None, parent=None, **kwargs):
'''
:param config: a module that configures this biothing
or its fully qualified name,
or its module file path.
'''
self._default = web_default
self._parent = parent # config package
self._user = self.load_module(config, object())
self.logger.info("%s", self._user) # log file location
# process keyword setting override
for key, value in kwargs.items():
setattr(self._user, key, value)
# process environment variable override of named settings
for name in os.environ:
if hasattr(self, name):
new_value = None
if isinstance(getattr(self, name), str):
new_value = os.environ[name]
elif isinstance(getattr(self, name), bool):
new_value = os.environ[name].lower() in ('true', '1')
if new_value is not None:
self.logger.info("$ %s = %s", name, os.environ[name])
setattr(self._user, name, new_value)
else: # cannot override dict, array, object type...
self.logger.error("Env %s is not suppored.", name)
# ----------- #
self.validate()
# ----------- #
self.fieldnote = FieldNote(self.AVAILABLE_FIELDS_NOTES_PATH)
self.devinfo = DevInfo(self.APP_GIT_REPOSITORY)
# initialize payload for standalone tracking batch
self.tracking_payload = []
self.optionsets = OptionSets()
self.handlers = {}
[docs] @staticmethod
def load_module(config, default=None):
"""
Ensure config is a module.
If config does not evaluate,
Return default if it's provided.
"""
if isinstance(config, types.ModuleType):
return config
elif isinstance(config, str) and config.endswith('.py'):
spec = importlib.util.spec_from_file_location("config", config)
config = importlib.util.module_from_spec(spec)
spec.loader.exec_module(config)
return config
elif isinstance(config, str) and config:
return import_module(config)
elif not config and default:
return default
raise BiothingConfigError()
def __getattr__(self, name):
if hasattr(self._user, name):
return getattr(self._user, name)
elif hasattr(self._parent, name):
return getattr(self._parent, name)
elif hasattr(self._default, name):
return getattr(self._default, name)
else: # not provided and no default
raise AttributeError(name)
@property
def logger(self):
return logging.getLogger('biothings.web.settings')
[docs] @staticmethod
def load_class(kls):
"""
Ensure config is a module.
If config does not evaluate,
Return default if it's provided.
"""
if inspect.isclass(kls):
return kls
if isinstance(kls, str):
return locate(kls)
raise BiothingConfigError()
def _generate_app_settings(self, override=None):
"""
Generates settings for tornado.web.Application. This result and the
method below can define a tornado application to start a web server.
"""
settings = {
'biothings': self,
'autoreload': False,
'debug': False,
}
settings.update(override or {})
supported_keywords = (
'default_handler_class', 'default_handler_args', 'template_path',
'log_function', 'compress_response', 'cookie_secret',
'login_url', 'static_path', 'static_url_prefix')
for setting in supported_keywords:
if hasattr(self, setting.upper()):
settings[setting] = getattr(self, setting.upper())
if __SENTRY_INSTALLED__ and self.SENTRY_CLIENT_KEY:
# Setup error monitoring with Sentry. More on:
# https://docs.sentry.io/clients/python/integrations/#tornado
settings['sentry_client'] = AsyncSentryClient(self.SENTRY_CLIENT_KEY)
return settings
def _generate_app_handlers(self, addons=None):
'''
Generates the tornado.web.Application `(regex, handler_class, options) tuples
<http://www.tornadoweb.org/en/stable/web.html#application-configuration>`_.
'''
handlers = {}
addons = addons or []
for rule in self.APP_LIST + addons:
pattern = rule[0]
handler = self.load_class(rule[1])
setting = rule[2] if len(rule) == 3 else {}
assert handler, rule[1]
if issubclass(handler, BaseAPIHandler) and handler.name:
handler_name = handler.name
handler_options = handler.kwargs
setting_attr = '_'.join((handler_name, 'kwargs')).upper()
setting_options = getattr(self, setting_attr, {})
self.optionsets.add(handler_name, setting_options)
self.optionsets.add(handler_name, handler_options, handler.kwarg_groups)
if '{typ}' in pattern:
if not issubclass(handler, BaseESRequestHandler):
raise BiothingConfigError()
for biothing_type in self.BIOTHING_TYPES:
_pattern = pattern.format(
pre=self.API_PREFIX,
ver=self.API_VERSION,
typ=biothing_type).replace('//', '/')
_setting = dict(setting)
_setting['biothing_type'] = biothing_type
handlers[_pattern] = (_pattern, handler, _setting)
elif '{pre}' in pattern or '{ver}' in pattern:
pattern = pattern.format(
pre=self.API_PREFIX,
ver=self.API_VERSION).replace('//', '/')
if '()' not in pattern:
handlers[pattern] = (pattern, handler, setting)
else: # no pattern translation
handlers[pattern] = (pattern, handler, setting)
self.handlers = handlers
handlers = list(handlers.values())
self.logger.info('API Handlers:\n%s', pformat(handlers, width=200))
return handlers
[docs] def get_app(self, settings=False, handlers=None):
"""
Return the tornado.web.Application defined by this settings.
This is primarily how an HTTP server interacts with this class.
Additional settings and handlers accepted as parameters.
"""
# config package
if self._user.__name__ == self._user.__package__:
attrs = [getattr(self._user, attr) for attr in dir(self._user)]
confs = [attr for attr in attrs if isinstance(attr, types.ModuleType)]
_settings = [self.__class__(_attr, self._user) for _attr in confs]
_handlers = [(f'/{c.API_PREFIX}/.*', c.get_app(settings)) for c in _settings]
_handlers += handlers or [] # second level front pages won't be exposed
else: # config module
_handlers = self._generate_app_handlers(handlers)
_settings = self._generate_app_settings(settings)
return Application(_handlers, **_settings)
[docs] def validate(self):
'''
Validate the settings defined for this web server.
'''
assert self.API_VERSION or self.API_PREFIX
assert isinstance(self.LIST_SIZE_CAP, int)
assert isinstance(self.ACCESS_CONTROL_ALLOW_METHODS, str)
assert isinstance(self.ACCESS_CONTROL_ALLOW_HEADERS, str)
self.ES_INDICES = dict(self.ES_INDICES)
self.ES_INDICES[self.ES_DOC_TYPE] = self.ES_INDEX
self.BIOTHING_TYPES = list(self.ES_INDICES.keys())
[docs]class BiothingESWebSettings(BiothingWebSettings):
"""
With additional settings pecific to an elasticsearch backend.
"""
def __init__(self, config=None, parent=None, **kwargs):
super(BiothingESWebSettings, self).__init__(config, parent, **kwargs)
# user query data
self.userquery = ESUserQuery(self.USERQUERY_DIR)
self.connections = DataConnections(self)
self.metadata = DataMetadata(self)
self.pipeline = DataPipeline(self)
IOLoop.current().add_callback(self._initialize)
async def _initialize(self):
# failures will be logged concisely
logging.getLogger('elasticsearch.trace').propagate = False
await self.connections.log_versions()
# populate source mappings
for biothing_type in self.ES_INDICES:
await self.metadata.refresh(biothing_type)
# resume normal log flow
logging.getLogger('elasticsearch.trace').propagate = True
[docs] def validate(self):
'''
Additional ES settings to validate.
'''
super().validate()
assert isinstance(self.ES_INDEX, str)
assert isinstance(self.ES_DOC_TYPE, str)
assert isinstance(self.ES_INDICES, dict)
assert '*' not in self.ES_DOC_TYPE