unify sanic log output with synse-server log output

requirements.txt

@@ -27,6 +27,7 @@ pyasn1==0.4.5             # via pyasn1-modules, rsa
 pycparser==2.19           # via cffi
 pyjwt==1.7.1              # via adal
 python-dateutil==2.8.0    # via adal, kubernetes
+python-json-logger==0.1.10
 pyyaml==4.2b4
 requests-oauthlib==1.2.0  # via kubernetes
 requests==2.21.0

setup.py

@@ -41,6 +41,7 @@
         'bison>=0.1.0',
         'grpcio',
         'kubernetes',
+        'python-json-logger',
         'pyyaml>=4.2b1',
         'requests>=2.20.0',  # used by 'kubernetes'
         'sanic>=0.8.0',

synse_server/api/http.py

@@ -3,6 +3,8 @@
 from sanic import Blueprint
 from sanic.response import text
 
+from synse_server.log import logger
+
 # Blueprint for the Synse core (version-less) routes.
 core = Blueprint('core-http')
 

synse_server/app.py

@@ -17,6 +17,7 @@ def new_app():
     app = Sanic(
         name='synse-server',
         error_handler=errors.SynseErrorHandler(),
+        configure_logging=False,
     )
 
     # Disable the default Sanic logo.

synse_server/log.py

@@ -1,12 +1,57 @@
 """Synse Server application logging."""
 
 import logging
+import logging.config
 import sys
 
 import structlog
 
 from synse_server import config
 
+logging.config.dictConfig({
+    'version': 1,
+    'disable_existing_loggers': False,
+    'loggers': {
+        'root': {
+            'level': 'INFO',
+            'handlers': ['default']
+        },
+        'sanic.error': {
+            'level': 'INFO',
+            'handlers': ['error'],
+            'propagate': True,
+            'qualname': 'sanic.error'
+        },
+        'sanic.access': {
+            'level': 'INFO',
+            'handlers': ['default'],
+            'propagate': True,
+            'qualname': 'sanic.access'
+        },
+        'synse-server': {
+            'level': 'INFO',
+            'handlers': ['default']
+        },
+    },
+    'handlers': {
+        'default': {
+            'class': 'logging.StreamHandler',
+            'formatter': 'json',
+            'stream': sys.stdout
+        },
+        'error': {
+            'class': 'logging.StreamHandler',
+            'formatter': 'json',
+            'stream': sys.stderr
+        },
+    },
+    'formatters': {
+        'json': {
+            'class': 'pythonjsonlogger.jsonlogger.JsonFormatter'
+        },
+    }
+})
+
 structlog.configure(
     processors=[
         structlog.stdlib.filter_by_level,
@@ -16,25 +61,18 @@
         structlog.processors.StackInfoRenderer(),
         structlog.processors.format_exc_info,
         structlog.processors.UnicodeDecoder(),
-        structlog.processors.KeyValueRenderer(
-            key_order=['timestamp', 'level', 'event'],
-        ),
+        structlog.stdlib.render_to_log_kwargs,
     ],
     context_class=dict,
     logger_factory=structlog.stdlib.LoggerFactory(),
     wrapper_class=structlog.stdlib.BoundLogger,
     cache_logger_on_first_use=True,
 )
 
-
 logger = structlog.get_logger('synse-server')
 
 
 def setup_logger():
     """Configure the Synse Server logger."""
     level = logging.getLevelName(config.options.get('logging', 'info').upper())
-    logging.basicConfig(
-        format='%(message)s',
-        stream=sys.stdout,
-        level=level,
-    )
+    logger.setLevel(level)

synse_server/server.py

@@ -80,8 +80,8 @@ def _setup(self):
 
         # Make sure that the filesystem layout needed by Synse Server
         # is present. If not, create the required directories.
-        os.makedirs(path=self._server_config_dir, exist_ok=True)
-        os.makedirs(path=self._socket_dir, exist_ok=True)
+        os.makedirs(self._server_config_dir, exist_ok=True)
+        os.makedirs(self._socket_dir, exist_ok=True)
 
         # Load the application configuration(s).
         self.reload_config()