在cosmosdb中创建文档时取消

Question

我们正在使用cosmosdb记录我们的应用程序日志。我们的日志有两层，一层有一般的信息，另一层有一般日志的更详细的信息。我们还在其他两个集合中记录了这些的副本以供备份。所以我们总共有四个系列。在我们的代码中，我们使用异步CreateDocumentAsync来创建这些日志。我们将任务存储在列表中，并使用Task.waitall来完成所有任务。在开发环境中，我们没有看到任何错误，但在生产中，当创建新文档时，我们会在应用程序洞察中看到取消的错误。下面的示例图片。

下面是我们正在使用的代码结构

API控制器代码

public void Log(LogModel logObject)
{
    try
    {
        _context.Save(logObject);
    }
    catch(Exception ex)
    {
        _azureTelemtry.TrackTrace($"Exception occured: {ex.ToString()}");
    }
}

上下文保存方法

public void Save(LogModel logObject)
{
    List<Task> saveTasks = new List<Task>();
    LogInfo logInfo = logObject.logInfo;
    LogDetails logDetails = logObject.logDetails;
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, primaryLogInfoCollectionID), logInfo));
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, archieveLogInfoCollectionID), logInfo));    
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, primaryLogDetailsCollectionID), logDetails));
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, archieveLogDetailsCollectionID), logDetails));
    Task.WaitAll(saveTasks.ToArrays());
}

异常详细信息

Answer 1

您不等待任务。此外，save函数是同步的，因此task.waitall（savetasks.toArrays（））；运行synchronpusly。

至少我认为public void Save（LogModel logObject）应该是public Task Save（LogModel logObject）和Task.waitall(savetasks.toarrays())；应该是return Task.whenall(savetasks.toarrays())；

public Task Save(LogModel logObject)
{
    List<Task> saveTasks = new List<Task>();
    LogInfo logInfo = logObject.logInfo;
    LogDetails logDetails = logObject.logDetails;
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, primaryLogInfoCollectionID), logInfo));
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, archieveLogInfoCollectionID), logInfo));    
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, primaryLogDetailsCollectionID), logDetails));
    saveTasks.Add(documentClient.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(DatabaseId, archieveLogDetailsCollectionID), logDetails));

    return Task.WhenAll(saveTasks.ToArrays());
}

如果您的意图是激发任务并忘记，现在可以使用_context.save(logObject)；，但除此之外，您需要使用task

另一个问题是：上面的代码打开了4个任务，无法控制地处理它。NET Core中的默认并发执行限制为10。现在，假设save方法先后调用了三次，但都没有完成。这意味着您需要有12个并发任务。但是。NET核心的限制是10个。我相信最后两个任务将被取消。