Fix streaming ingestion

packages/azure-kusto-ingest/src/streamingIngestClient.browser.ts

@@ -28,6 +28,7 @@ class KustoStreamingIngestClient extends KustoStreamingIngestClientBase {
             descriptor.stream,
             props.format,
             props.ingestionMappingReference ?? null,
+            undefined,
             clientRequestId,
         );
     }

packages/azure-kusto-ingest/src/streamingIngestClient.ts

@@ -41,6 +41,7 @@ class KustoStreamingIngestClient extends KustoStreamingIngestClientBase {
             compressedStream,
             props.format,
             props.ingestionMappingReference ?? null,
+            undefined,
             clientRequestId,
         );
     }

packages/azure-kusto-ingest/test/e2eTests/e2eTest.ts

@@ -26,7 +26,7 @@
     IngestionResult,
 } from "azure-kusto-ingest";
 
 import { type AxiosError } from "axios";
 
 import { sleep } from "../../src/retry.js";
 
@@ -38,6 +38,7 @@
 import { basename, dirname } from "path";
 import sinon from "sinon";
 import { fileURLToPath } from "url";
+import { BlockBlobClient, ContainerClient } from "@azure/storage-blob";
 
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = dirname(__filename);
@@ -338,14 +339,23 @@
                     .filter((i) => i.testOnStreamingIngestion)
                     .map((i) => {
                         return { item: i };
-                    }),
+                    })
             )("ingestFromBlob_$item.description", async ({ item }) => {
                 const blobName = uuidv4() + basename(item.path);
-                const blobUri = await ingestClient.uploadToBlobWithRetry(item.path, blobName);
+                const result = await dmKustoClient.execute(databaseName, ".show export containers");
+                const container = result.primaryResults?.[0]?.toJSON<{"StorageRoot": string}>().data[0].StorageRoot;
+                if (!container) {
+                    assert.fail("Failed to get export containers");
+                }
+                const blockBlobClient = (new ContainerClient(container)).getBlockBlobClient(blobName);
+                const response = await blockBlobClient.uploadFile(item.path);
+                if (response.errorCode) {
+                    assert.fail(`Failed to upload blob ${JSON.stringify(response)}`);
+                }
 
                 const table = tableNames[("streaming_blob" + "_" + item.description) as Table];
                 try {
-                    await streamingIngestClient.ingestFromBlob(blobUri, item.ingestionPropertiesCallback(table));
+                    await streamingIngestClient.ingestFromBlob(blockBlobClient.url, item.ingestionPropertiesCallback(table));
                 } catch (err) {
                     assert.fail(`Failed to ingest ${item.description} - ${util.format(err)}`);
                 }