in src/Ingestor.cs [936:959]
private void UploadFiles(DataSource fileRef, IPersistentStorageContainer blobContainer)
{
try
{
if (blobContainer != null)
{
var blobName = Path.GetFileName(ExtendedPath.RandomizeFileName(fileRef.FileSystemPath));
var blobReference = blobContainer.CreateFileRef(blobName);
blobReference.UploadFromFileAsync(fileRef.FileSystemPath).WaitEx();
fileRef.CloudFileUri = blobReference.GetUnsecureUri();
fileRef.SafeCloudFileUri = blobReference.GetFileUri();
}
lock (m_listIntermediateSourcesLock)
{
m_listIntermediateSources.Add(fileRef);
}
Interlocked.Increment(ref m_filesUploaded);
}
catch (Exception ex)
{
m_logger.LogError($"UploadFiles failed: {ex.Message}");
}
}