private IPersistentStorageContainer AcquireTempBlobContainer()

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;
        }