[Azure.Monitor.Ingestion] update Bicep file for live testing (#31803)

Author: nisha-bhatia

sdk/monitor/Azure.Monitor.Ingestion/tests/MonitorIngestionLiveTest.cs

@@ -104,7 +104,7 @@ private static List<Object> GenerateEntries(int numEntries, DateTime recordingNo
         [Test]
         public async Task ValidInputFromArrayAsJsonWithSingleBatchWithGzip()
         {
-            LogsIngestionClient client = CreateClient();
+           LogsIngestionClient client = CreateClient();
 
            // Make the request
            var response = await client.UploadAsync(TestEnvironment.DCRImmutableId, TestEnvironment.StreamName, GenerateEntries(10, Recording.Now.DateTime)).ConfigureAwait(false);
@@ -119,28 +119,16 @@ public async Task ValidInputFromArrayAsJsonWithSingleBatchWithGzip()
         public async Task ValidInputFromArrayAsJsonWithMultiBatchWithGzip()
         {
             LogsIngestionClient client = CreateClient();
+            LogsIngestionClient.SingleUploadThreshold = 500; // make batch size smaller for Uploads for test recording size
 
             // Make the request
-            var response = await client.UploadAsync(TestEnvironment.DCRImmutableId, TestEnvironment.StreamName, GenerateEntries(10000, Recording.Now.DateTime)).ConfigureAwait(false);
+            var response = await client.UploadAsync(TestEnvironment.DCRImmutableId, TestEnvironment.StreamName, GenerateEntries(1000, Recording.Now.DateTime)).ConfigureAwait(false);
 
             // Check the response
             Assert.AreEqual(UploadLogsStatus.Success, response.Value.Status);
             Assert.IsEmpty(response.Value.Errors);
         }
 
-        [LiveOnly]
-        [Test]
-        public async Task InvalidInputFromObjectAsJsonNoBatchingNoGzipAsync()
-        {
-            LogsIngestionClient client = CreateClient();
-
-            Response<UploadLogsResult> response = await client.UploadAsync(TestEnvironment.DCRImmutableId, TestEnvironment.StreamName, GenerateEntries(10000, Recording.Now.DateTime)).ConfigureAwait(false); //takes StreamName not tablename
-            // Check the response - run without Batching and Gzip for error 413
-            Assert.AreEqual(UploadLogsStatus.Failure, response.Value.Status);
-            Assert.AreEqual(413, response.Value.Errors.FirstOrDefault().Error.Code);
-            Assert.AreEqual(10000, response.Value.Errors.FirstOrDefault().FailedLogs.Count());
-        }
-
         [AsyncOnly]
         [Test]
         public async Task ConcurrencyMultiThread()

sdk/monitor/Azure.Monitor.Ingestion/tests/MonitorIngestionTestEnvironment.cs

@@ -1,22 +1,20 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
-using System;
 using Azure.Core.TestFramework;
-using Azure.Identity;
 
 namespace Azure.Monitor.Ingestion.Tests
 {
     public class MonitorIngestionTestEnvironment : TestEnvironment
     {
-        public string DCRImmutableId => GetRecordedVariable("AZURE_MONITOR_INGESTION_LOGS_DCR_RULE_ID");
+        public string DCRImmutableId => GetRecordedVariable("INGESTION_DATA_COLLECTION_RULE_IMMUTABLE_ID");
 
-        public string DCREndpoint => GetRecordedVariable("AZURE_MONITOR_INGESTION_DATA_COLLECTION_ENDPOINT");
+        public string DCREndpoint => GetRecordedVariable("INGESTION_DATA_COLLECTION_ENDPOINT");
 
-        public string Ingestion_WorkspaceId => GetRecordedVariable("AZURE_MONITOR_INGESTION_INGESTION_WORKSPACE_ID");
+        public string Ingestion_WorkspaceId => GetRecordedVariable("WORKSPACE_ID");
 
-        public string StreamName => GetRecordedVariable("AZURE_MONITOR_INGESTION_LOGS_DCR_STREAM_NAME");
+        public string StreamName => GetRecordedVariable("INGESTION_STREAM_NAME");
 
-        public string TableName => GetRecordedVariable("AZURE_MONITOR_INGESTION_LOGS_TABLE_NAME");
+        public string TableName => GetRecordedVariable("INGESTION_TABLE_NAME");
     }
 }