[Monitor OpenTelemetry Exporter] Silence All SDK Stats Error Logging

sdk/monitor/monitor-opentelemetry-exporter/CHANGELOG.md

@@ -11,6 +11,7 @@
 ### Other Changes
 
 - Detect AKS when the `KUBERNETES_SERVICE_HOST` environment variable is defined.
+- Statsbeat exports now report success on failed sends to prevent PeriodicExportingMetricReader errors from surfacing to customers.
 
 ## 1.0.0-beta.36 (2025-11-10)
 

sdk/monitor/monitor-opentelemetry-exporter/src/Declarations/Constants.ts

@@ -122,6 +122,12 @@ export const ENV_APPLICATIONINSIGHTS_SDKSTATS_ENABLED_PREVIEW =
 export const ENV_APPLICATIONINSIGHTS_SDKSTATS_EXPORT_INTERVAL =
   "APPLICATIONINSIGHTS_SDKSTATS_EXPORT_INTERVAL";
 
+/**
+ * Enable verbose statsbeat logging and surfacing failures.
+ * @internal
+ */
+export const ENV_SDK_STATS_LOGGING = "SDK_STATS_LOGGING";
+
 /**
  * QuickPulse metric counter names.
  * @internal

sdk/monitor/monitor-opentelemetry-exporter/src/platform/nodejs/baseSender.ts

@@ -23,6 +23,7 @@ import type { TelemetryItem as Envelope } from "../../generated/index.js";
 import {
   ENV_APPLICATIONINSIGHTS_SDKSTATS_ENABLED_PREVIEW,
   ENV_APPLICATIONINSIGHTS_SDKSTATS_EXPORT_INTERVAL,
+  ENV_SDK_STATS_LOGGING,
   RetriableRestErrorTypes,
 } from "../../Declarations/Constants.js";
 import { CustomerSDKStatsMetrics } from "../../export/statsbeat/customerSDKStats.js";
@@ -207,9 +208,9 @@ export abstract class BaseSender {
               statusCode,
             );
           }
-          return {
+          return this.buildExportResult({
             code: ExportResultCode.FAILED,
-          };
+          });
         } else {
           // calls resultCallback(ExportResult) based on result of persister.push
           if (!this.isStatsbeatSender) {
@@ -230,9 +231,9 @@ export abstract class BaseSender {
           this.incrementStatsbeatFailure();
           this.customerSDKStatsMetrics?.countDroppedItems(envelopes, DropCode.CLIENT_EXCEPTION);
         }
-        return {
+        return this.buildExportResult({
           code: ExportResultCode.FAILED,
-        };
+        });
       }
     } catch (error: any) {
       const restError = error as RestError;
@@ -265,7 +266,7 @@ export abstract class BaseSender {
               ExceptionType.CLIENT_EXCEPTION,
             );
           }
-          return { code: ExportResultCode.FAILED, error: redirectError };
+          return this.buildExportResult({ code: ExportResultCode.FAILED, error: redirectError });
         }
       } else if (
         restError.statusCode &&
@@ -325,7 +326,7 @@ export abstract class BaseSender {
           restError.message,
         );
       }
-      return { code: ExportResultCode.FAILED, error: restError };
+      return this.buildExportResult({ code: ExportResultCode.FAILED, error: restError });
     }
   }
 
@@ -337,10 +338,10 @@ export abstract class BaseSender {
       const success = await this.persister.push(envelopes);
       return success
         ? { code: ExportResultCode.SUCCESS }
-        : {
+        : this.buildExportResult({
             code: ExportResultCode.FAILED,
             error: new Error("Failed to persist envelope in disk."),
-          };
+          });
     } catch (ex: any) {
       if (!this.isStatsbeatSender) {
         this.networkStatsbeatMetrics?.countWriteFailure();
@@ -351,7 +352,7 @@ export abstract class BaseSender {
           );
         }
       }
-      return { code: ExportResultCode.FAILED, error: ex };
+      return this.buildExportResult({ code: ExportResultCode.FAILED, error: ex });
     }
   }
 
@@ -402,4 +403,13 @@ export abstract class BaseSender {
     }
     return false;
   }
+
+  // Silence noisy failures from statsbeat OTel metric readers unless logging is explicitly enabled
+  private buildExportResult(result: ExportResult): ExportResult {
+    const shouldSurfaceStatsbeatFailures = !!process.env[ENV_SDK_STATS_LOGGING];
+    if (this.isStatsbeatSender && result.code === ExportResultCode.FAILED) {
+      return shouldSurfaceStatsbeatFailures ? result : { code: ExportResultCode.SUCCESS };
+    }
+    return result;
+  }
 }

sdk/monitor/monitor-opentelemetry-exporter/test/internal/baseSender.spec.ts

@@ -578,6 +578,76 @@ describe("BaseSender", () => {
 
       expect(diag.error).not.toHaveBeenCalled();
     });
+
+    it("should report success when statsbeat sender encounters non-retriable failure", async () => {
+      const originalEnv = process.env;
+      const newEnv = { ...process.env } as NodeJS.ProcessEnv;
+      delete newEnv.SDK_STATS_LOGGING;
+      process.env = newEnv;
+
+      sender = new TestBaseSender({
+        endpointUrl: "https://example.com",
+        instrumentationKey: "test-key",
+        trackStatsbeat: true,
+        exporterOptions: {},
+        isStatsbeatSender: true,
+      });
+
+      sender.sendMock.mockResolvedValue({
+        statusCode: 400,
+        result: "",
+      });
+
+      const result = await sender.exportEnvelopes([{ name: "test", time: new Date() }]);
+
+      expect(result.code).toBe(ExportResultCode.SUCCESS);
+
+      process.env = originalEnv;
+    });
+
+    it("should surface failure when SDK_STATS_LOGGING is enabled for statsbeat sender", async () => {
+      const originalEnv = process.env;
+      const newEnv = { ...process.env, SDK_STATS_LOGGING: "true" } as NodeJS.ProcessEnv;
+      process.env = newEnv;
+
+      sender = new TestBaseSender({
+        endpointUrl: "https://example.com",
+        instrumentationKey: "test-key",
+        trackStatsbeat: true,
+        exporterOptions: {},
+        isStatsbeatSender: true,
+      });
+
+      sender.sendMock.mockResolvedValue({
+        statusCode: 400,
+        result: "",
+      });
+
+      const result = await sender.exportEnvelopes([{ name: "test", time: new Date() }]);
+
+      expect(result.code).toBe(ExportResultCode.FAILED);
+
+      process.env = originalEnv;
+    });
+
+    it("should keep failure result for customer sender non-retriable failure", async () => {
+      sender = new TestBaseSender({
+        endpointUrl: "https://example.com",
+        instrumentationKey: "test-key",
+        trackStatsbeat: true,
+        exporterOptions: {},
+        isStatsbeatSender: false,
+      });
+
+      sender.sendMock.mockResolvedValue({
+        statusCode: 400,
+        result: "",
+      });
+
+      const result = await sender.exportEnvelopes([{ name: "test", time: new Date() }]);
+
+      expect(result.code).toBe(ExportResultCode.FAILED);
+    });
   });
 
   describe("Performance Counter Detection", () => {