diff --git a/ecs_logging/_stdlib.py b/ecs_logging/_stdlib.py index f7d7dae..2de6e6d 100644 --- a/ecs_logging/_stdlib.py +++ b/ecs_logging/_stdlib.py @@ -183,6 +183,7 @@ def format_to_ecs(self, record): extras["transaction.id"] = extras.pop("elasticapm_transaction_id", None) extras["trace.id"] = extras.pop("elasticapm_trace_id", None) extras["service.name"] = extras.pop("elasticapm_service_name", None) + extras["event.dataset"] = extras.pop("elasticapm_event_dataset", None) # Merge in any keys that were set within 'extra={...}' for field, value in extras.items():