You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
There is redundant code to load documents into Cosmos in Pipelines. This should be part of the DocumentLoader class.
Example of code:
int docsLoaded = 0;
int docsError = 0;
foreach(SoilSample sample in transformed)
{
ResourceResponse<Document> result =
await loader.LoadNoReplace(sample);
if(result.StatusCode == HttpStatusCode.Created)
{
etlEvent.Outputs.Add(result.Resource.Id);
docsLoaded++;
}
else { docsError++; }
// Notify data written then sleep to conserve Cosmos RU
Console.Write(".");
Thread.Sleep(40);
}
Function should take "Thread.Sleep" as argument
Function should return a list of successes (or a string?) and list of errors. Possibly a tuple. This info needs to be logged in an EtlEvent:
There is redundant code to load documents into Cosmos in Pipelines. This should be part of the DocumentLoader class.
Example of code:
Function should take "Thread.Sleep" as argument
Function should return a list of successes (or a string?) and list of errors. Possibly a tuple. This info needs to be logged in an EtlEvent:
The text was updated successfully, but these errors were encountered: