diff --git a/query-engine/connectors/mongodb-query-connector/src/root_queries/mod.rs b/query-engine/connectors/mongodb-query-connector/src/root_queries/mod.rs index 4339af46436..4a85857b1ad 100644 --- a/query-engine/connectors/mongodb-query-connector/src/root_queries/mod.rs +++ b/query-engine/connectors/mongodb-query-connector/src/root_queries/mod.rs @@ -73,6 +73,8 @@ where user_facing = true, "db.system" = SYSTEM_NAME, "db.statement" = %Arc::clone(&query_string), + "db.collection.name" = %builder.collection().unwrap_or_else(|| "raw"), + "db.operation.name" = builder.query_type(), "otel.kind" = "client" ); diff --git a/query-engine/core/src/telemetry/models.rs b/query-engine/core/src/telemetry/models.rs index 43ffe3a1f32..24247c2f4cf 100644 --- a/query-engine/core/src/telemetry/models.rs +++ b/query-engine/core/src/telemetry/models.rs @@ -7,7 +7,14 @@ use std::{ time::{Duration, SystemTime}, }; -const ACCEPT_ATTRIBUTES: &[&str] = &["db.system", "db.statement", "itx_id", "otel.kind"]; +const ACCEPT_ATTRIBUTES: &[&str] = &[ + "db.system", + "db.statement", + "db.collection.name", + "db.operation.name", + "itx_id", + "otel.kind", +]; #[derive(Serialize, Debug, Clone, PartialEq, Eq)] pub enum OtelKind {