[APM] Hash service name/environment for APM per_service telemetry (#1…

…41685) (#141822) * Hash service name/environment for per_service telemetry * Fix typing and reorder service name/env Co-authored-by: Kibana Machine <[email protected]> (cherry picked from commit 90b9afd) Co-authored-by: Colton Myers <[email protected]>
elastic · Sep 26, 2022 · 80fa506 · 80fa506
1 parent aac7c34
commit 80fa506
Showing 1 changed file with 8 additions and 3 deletions.
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
@@ -6,6 +6,7 @@
  */
 import { fromKueryExpression } from '@kbn/es-query';
 import { flatten, merge, sortBy, sum, pickBy } from 'lodash';
+import { createHash } from 'crypto';
 import type * as estypes from '@elastic/elasticsearch/lib/api/typesWithBodyKey';
 import { ProcessorEvent } from '@kbn/observability-plugin/common';
 import { asMutableArray } from '../../../../common/utils/as_mutable_array';
@@ -1247,11 +1248,15 @@ export const tasks: TelemetryTask[] = [
       });
       const envBuckets = response.aggregations?.environments.buckets ?? [];
       const data: APMPerService[] = envBuckets.flatMap((envBucket) => {
-        const env = envBucket.key;
+        const envHash = createHash('sha256')
+          .update(envBucket.key as string)
+          .digest('hex');
         const serviceBuckets = envBucket.service_names?.buckets ?? [];
         return serviceBuckets.map((serviceBucket) => {
-          const name = serviceBucket.key;
-          const fullServiceName = `${env}~${name}`;
+          const nameHash = createHash('sha256')
+            .update(serviceBucket.key as string)
+            .digest('hex');
+          const fullServiceName = `${nameHash}~${envHash}`;
           return {
             service_id: fullServiceName,
             timed_out: response.timed_out,