Merge pull request AzureCosmosDB#119 from CityStructure/cosmosdb-addrate

bowencode · web-flow · commit b25e81906478 · 2024-03-29T15:28:46.000-07:00
include AddRate when reporting progress
diff --git a/Extensions/Cosmos/Cosmos.DataTransfer.CosmosExtension/CosmosDataSinkExtension.cs b/Extensions/Cosmos/Cosmos.DataTransfer.CosmosExtension/CosmosDataSinkExtension.cs
@@ -89,7 +89,7 @@ void ReportCount(int i)
                 addedCount += i;
                 if (addedCount % 500 == 0)
                 {
-                    logger.LogInformation("{AddedCount} records added after {TotalSeconds}s", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}");
+                    logger.LogInformation("{AddedCount} records added after {TotalSeconds}s ({AddRate} records/s)", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}", $"{(int)(addedCount / (timer.ElapsedMilliseconds / 1000.0))}");
                 }
             }
 
@@ -111,7 +111,7 @@ void ReportCount(int i)
                 throw new Exception($"Only {addedCount} of {inputCount} records were added to Cosmos");
             }
 
-            logger.LogInformation("Added {AddedCount} total records in {TotalSeconds}s", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}");
+            logger.LogInformation("Added {AddedCount} total records in {TotalSeconds}s ({AddRate} records/s)", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}", $"{(int)(addedCount / (timer.ElapsedMilliseconds / 1000.0))}");
         }
 
         private static AsyncRetryPolicy GetRetryPolicy(int maxRetryCount, int initialRetryDuration)

Original file line number	Diff line number	Diff line change
`@@ -89,7 +89,7 @@ void ReportCount(int i)`
`89`	`89`	`addedCount += i;`
`90`	`90`	`if (addedCount % 500 == 0)`
`91`	`91`	`{`
`92`		`- logger.LogInformation("{AddedCount} records added after {TotalSeconds}s", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}");`
	`92`	`+ logger.LogInformation("{AddedCount} records added after {TotalSeconds}s ({AddRate} records/s)", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}", $"{(int)(addedCount / (timer.ElapsedMilliseconds / 1000.0))}");`
`93`	`93`	`}`
`94`	`94`	`}`
`95`	`95`
`@@ -111,7 +111,7 @@ void ReportCount(int i)`
`111`	`111`	`throw new Exception($"Only {addedCount} of {inputCount} records were added to Cosmos");`
`112`	`112`	`}`
`113`	`113`
`114`		`- logger.LogInformation("Added {AddedCount} total records in {TotalSeconds}s", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}");`
	`114`	`+ logger.LogInformation("Added {AddedCount} total records in {TotalSeconds}s ({AddRate} records/s)", addedCount, $"{timer.ElapsedMilliseconds / 1000.0:F2}", $"{(int)(addedCount / (timer.ElapsedMilliseconds / 1000.0))}");`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`private static AsyncRetryPolicy GetRetryPolicy(int maxRetryCount, int initialRetryDuration)`