improve

Author: GuillaumeVadeBe

Extensions/AzureBlob/Cosmos.DataTransfer.AzureBlobStorage/AzureBlobDataSink.cs

@@ -41,7 +41,7 @@ public async Task WriteToTargetAsync(Func<Stream, Task> writeToStream, IConfigur
 
             logger.LogInformation("Saving file '{File}' to Azure Blob Container '{ContainerName}'", settings.BlobName, settings.ContainerName);
 
-            var lastLogTime = DateTime.MinValue;
+            var lastLogTime = DateTime.UtcNow;
             var logInterval = TimeSpan.FromMinutes(1);
             long totalBytes = 0;
 
@@ -54,32 +54,31 @@ public async Task WriteToTargetAsync(Func<Stream, Task> writeToStream, IConfigur
                 {
                     if (DateTime.UtcNow - lastLogTime >= logInterval)
                     {
-                        logger.LogInformation("Transferred {TotalMiB} bytes to Azure Blob", l/1024/1024);
+                        logger.LogInformation("{BlobName}: transferred {TotalMiB} MiB to Azure Blob", settings.BlobName, l / 1024/1024);
                         lastLogTime = DateTime.UtcNow;
                     }
 
                     totalBytes = l;
                 })
 
             }, cancellationToken);
+
             await writeToStream(blobStream);
 
             sw.Stop();
 
-            var totalMib = totalBytes / 1024 / 1024;
-            var rate = totalMib / sw.ElapsedMilliseconds / 1000;
+            if (totalBytes != 0)
+            {
+                var totalMib = totalBytes / 1024 / 1024;
+                var rate = totalMib / sw.ElapsedMilliseconds / 1000;
 
-            logger.LogInformation("Transferred {TotalMiB} Mib to Azure Blob in {TotalTime} minutes ({Rate} MiB/s).", totalMib, sw.ElapsedMilliseconds/1000/60, rate);
+                logger.LogInformation("{BlobName}: transferred {TotalMiB} Mib to Azure Blob in {TotalTime} minutes ({Rate} MiB/s).", settings.BlobName, totalMib, sw.ElapsedMilliseconds / 1000 / 60, rate);
+            }
         }
 
         public IEnumerable<IDataExtensionSettings> GetSettings()
         {
             yield return new AzureBlobSinkSettings();
         }
-
-        private void LogBytes()
-        {
-
-        }
     }
 }