[APM] Add telemetry for the cardinality of span.destination.service.r…

…esource (#162424) Add telemetry about the cardinality of `span.destination.service.resource` within the last day. The indexer will be updated by elastic/telemetry#2402. Closes #161986 --------- Co-authored-by: Kibana Machine <[email protected]>
elastic · Jul 25, 2023 · f1fca32 · f1fca32
1 parent 02b04dd
commit f1fca32
Show file tree

Hide file tree

Showing 5 changed files with 60 additions and 0 deletions.
diff --git a/x-pack/plugins/apm/common/__snapshots__/apm_telemetry.test.ts.snap b/x-pack/plugins/apm/common/__snapshots__/apm_telemetry.test.ts.snap
diff --git a/x-pack/plugins/apm/server/lib/apm_telemetry/collect_data_telemetry/tasks.ts b/x-pack/plugins/apm/server/lib/apm_telemetry/collect_data_telemetry/tasks.ts
@@ -42,6 +42,7 @@ import {
   TRANSACTION_RESULT,
   TRANSACTION_TYPE,
   USER_AGENT_ORIGINAL,
+  SPAN_DESTINATION_SERVICE_RESOURCE,
 } from '../../../../common/es_fields/apm';
 import {
   APM_SERVICE_GROUP_SAVED_OBJECT_TYPE,
@@ -802,6 +803,32 @@ export const tasks: TelemetryTask[] = [
         },
       });
 
+      const spanDestinationServiceResourceCount = (
+        await telemetryClient.search({
+          index: indices.transaction,
+          body: {
+            track_total_hits: false,
+            size: 0,
+            timeout,
+            query: {
+              bool: {
+                filter: [
+                  { term: { [PROCESSOR_EVENT]: ProcessorEvent.span } },
+                  range1d,
+                ],
+              },
+            },
+          },
+          aggs: {
+            span_destination_service_resource: {
+              cardinality: {
+                field: SPAN_DESTINATION_SERVICE_RESOURCE,
+              },
+            },
+          },
+        })
+      ).aggregations?.span_destination_service_resource.value;
+
       return {
         counts: {
           max_error_groups_per_service: {
@@ -823,6 +850,9 @@ export const tasks: TelemetryTask[] = [
               servicesAndEnvironmentsCount.aggregations?.service_environments
                 .value || 0,
           },
+          span_destination_service_resource: {
+            '1d': spanDestinationServiceResourceCount || 0,
+          },
         },
       };
     },

diff --git a/x-pack/plugins/apm/server/lib/apm_telemetry/schema.ts b/x-pack/plugins/apm/server/lib/apm_telemetry/schema.ts
@@ -211,6 +211,15 @@ export const apmSchema: MakeSchemaFrom<APMUsage> = {
         },
       },
     },
+    span_destination_service_resource: {
+      '1d': {
+        ...long,
+        _meta: {
+          description:
+            'Total number of unique values of span.destination.service.resource within the last day',
+        },
+      },
+    },
   },
   cardinality: {
     client: { geo: { country_iso_code: { rum: timeframeMap1dSchema } } },

diff --git a/x-pack/plugins/apm/server/lib/apm_telemetry/types.ts b/x-pack/plugins/apm/server/lib/apm_telemetry/types.ts
@@ -109,6 +109,7 @@ export interface APMUsage {
     traces: TimeframeMap;
     services: TimeframeMap;
     environments: TimeframeMap1d;
+    span_destination_service_resource: TimeframeMap1d;
   };
   cardinality: {
     client: { geo: { country_iso_code: { rum: TimeframeMap1d } } };

diff --git a/x-pack/plugins/telemetry_collection_xpack/schema/xpack_plugins.json b/x-pack/plugins/telemetry_collection_xpack/schema/xpack_plugins.json
@@ -4011,6 +4011,16 @@
                   }
                 }
               }
+            },
+            "span_destination_service_resource": {
+              "properties": {
+                "1d": {
+                  "type": "long",
+                  "_meta": {
+                    "description": "Total number of unique values of span.destination.service.resource within the last day"
+                  }
+                }
+              }
             }
           }
         },