in src/Ingestor.cs [909:934]
private IPersistentStorageContainer AcquireTempBlobContainer(ICslAdminProvider kustoClient)
{
IPersistentStorageContainer blobContainerRef = null;
#if !OPEN_SOURCE_COMPILATION
try
{
var cmd = CslCommandGenerator.GenerateCreateTempStorageCommand();
var temp = kustoClient.ExecuteControlCommand(cmd);
var reader = ExtendedDataReader.ToEnumerable<TempStorageCreateCommandResult>(temp).ToList();
if (reader.SafeFastAny())
{
var uriWithSas = reader.First().StorageRoot;
if (!string.IsNullOrWhiteSpace(uriWithSas))
{
blobContainerRef = m_blob.CreateContainerRef(uriWithSas);
}
}
}
catch (Exception ex)
{
m_logger.LogError($"AcquireTempBlobContainer failed: {ex.Message}");
}
#endif
return blobContainerRef;
}