Add gunicorn_event_mapper

Author: RadoRado

gunicorn.conf.py

@@ -45,6 +45,42 @@ def combined_logformat(logger, name, event_dict):
     return event_dict
 
 
+def gunicorn_event_name_mapper(logger, name, event_dict):
+    logger_name = event_dict.get("logger")
+
+    if logger_name not in ["gunicorn.error", "gunicorn.access"]:
+        return event_dict
+
+    GUNICORN_BOOTING = "gunicorn.booting"
+    GUNICORN_REQUEST = "gunicorn.request_handling"
+    GUNICORN_SIGNAL = "gunicorn.signal_handling"
+
+    event = event_dict["event"].lower()
+
+    if logger_name == "gunicorn.error":
+        event_dict["message"] = event
+
+        if event.startswith("starting"):
+            event_dict["event"] = GUNICORN_BOOTING
+
+        if event.startswith("listening"):
+            event_dict["event"] = GUNICORN_BOOTING
+
+        if event.startswith("using"):
+            event_dict["event"] = GUNICORN_BOOTING
+
+        if event.startswith("booting"):
+            event_dict["event"] = GUNICORN_BOOTING
+
+        if event.startswith("handling signal"):
+            event_dict["event"] = GUNICORN_SIGNAL
+
+    if logger_name == "gunicorn.access":
+        event_dict["event"] = GUNICORN_REQUEST
+
+    return event_dict
+
+
 timestamper = structlog.processors.TimeStamper(fmt="iso", utc=True)
 pre_chain = [
     # Add the log level and a timestamp to the event_dict if the log entry
@@ -53,8 +89,10 @@ def combined_logformat(logger, name, event_dict):
     structlog.stdlib.add_logger_name,
     timestamper,
     combined_logformat,
+    gunicorn_event_name_mapper,
 ]
 
+# https://github.com/benoitc/gunicorn/blob/master/gunicorn/glogging.py#L47
 CONFIG_DEFAULTS = {
     "version": 1,
     "disable_existing_loggers": False,