[Monitor OpenTelemetry Exporter] Add Long-Interval Statsbeat Warmup Time

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

@@ -10,6 +10,7 @@
 
 - Fix setting statsbeat custom dimensions.
 - EAI_AGAIN REST errors are considered retriable.
+- Add 15 second warmup before export of long interval statsbeat.
 
 ## 1.0.0-beta.27 (2024-10-23)
 

sdk/monitor/monitor-opentelemetry-exporter/src/export/statsbeat/longIntervalStatsbeatMetrics.ts

@@ -127,15 +127,17 @@ class LongIntervalStatsbeatMetrics extends StatsbeatMetrics {
         [this.featureStatsbeatGauge],
       );
 
-      // Export Feature/Attach Statsbeat once upon app initialization
-      this.longIntervalAzureExporter.export(
-        (await this.longIntervalMetricReader.collect()).resourceMetrics,
-        (result: ExportResult) => {
-          if (result.code !== ExportResultCode.SUCCESS) {
-            diag.error(`LongIntervalStatsbeat: metrics export failed (error ${result.error})`);
-          }
-        },
-      );
+      // Export Feature/Attach Statsbeat once upon app initialization after 15 second delay
+      setTimeout(async () => {
+        this.longIntervalAzureExporter.export(
+          (await this.longIntervalMetricReader.collect()).resourceMetrics,
+          (result: ExportResult) => {
+            if (result.code !== ExportResultCode.SUCCESS) {
+              diag.error(`LongIntervalStatsbeat: metrics export failed (error ${result.error})`);
+            }
+          },
+        );
+      }, 15000); // 15 seconds
     } catch (error) {
       diag.debug("Call to get the resource provider failed.");
     }

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

@@ -171,8 +171,9 @@ describe("FileSystemPersist", () => {
       const secondBatch = [{ batch: "second" }];
       const success1 = await persister.push(firstBatch);
       assert.strictEqual(success1, true);
-      // wait 1 ms so that we don't overwrite previous file
-      await sleep(1);
+      // wait 100 ms so that we don't overwrite previous file
+      await sleep(100);
+
       const success2 = await persister.push(secondBatch);
       assert.strictEqual(success2, true);
       const value1 = await persister.shift();

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

@@ -393,6 +393,16 @@ describe("#AzureMonitorStatsbeatExporter", () => {
       });
     });
 
+    it("should wait 15 seconds from startup to export long interval statsbeat", async () => {
+      const longIntervalStatsbeat = getInstance(options);
+      const mockExport = vi.spyOn(longIntervalStatsbeat["longIntervalAzureExporter"], "export");
+      longIntervalStatsbeat["initialize"]();
+      expect(mockExport).not.toHaveBeenCalled();
+      setTimeout(async () => {
+        expect(mockExport).toHaveBeenCalled();
+      }, 15000);
+    });
+
     describe("Disable Non-Essential Statsbeat", () => {
       it("should disable statsbeat when the environement variable is set", () => {
         process.env[ENV_DISABLE_STATSBEAT] = "true";